给出一个常见的flink-conf.yaml
时间: 2023-07-18 12:30:14 浏览: 160
flink-conf.yaml
下面是一个常见的 flink-conf.yaml 配置文件的示例:
```yaml
# Flink JobManager 地址和端口
jobmanager.rpc.address: localhost
jobmanager.rpc.port: 6123
# Flink 任务管理器数量
taskmanager.numberOfTaskSlots: 4
# Flink 任务管理器的队列资源配置
taskmanager.memory.process.size: 4096m
taskmanager.memory.task.heap.size: 1024m
taskmanager.cpu.cores: 4
# Flink Checkpoint 配置
state.checkpoints.dir: file:///tmp/flink-checkpoints
state.savepoints.dir: file:///tmp/flink-savepoints
state.backend: filesystem
state.backend.fs.checkpointdir: file:///tmp/flink-checkpoints
# Flink Web UI 配置
web.frontend.port: 8081
web.upload.dir: /opt/flink-1.13.0/web-upload
# Flink 日志配置
log.file: /var/log/flink/flink.log
log4j.logger.org.apache.flink: INFO, file
log4j.logger.org.apache.flink.runtime: INFO, file
log4j.logger.org.apache.flink.streaming: INFO, file
log4j.logger.org.apache.flink.runtime.checkpoint: INFO, file
log4j.logger.org.apache.flink.runtime.webmonitor: INFO, file
log4j.logger.org.apache.flink.runtime.rest: INFO, file
```
以上是一个简单的 flink-conf.yaml 文件示例,其中包含了 Flink JobManager 和任务管理器的配置信息、队列资源的配置、Checkpoint 配置、Web UI 配置和日志配置等。需要注意的是,具体的配置信息可能因 Flink 版本和集群环境而异,您需要根据自己的需求进行相应的调整。
阅读全文