1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
jobmanager.rpc.port: 6123
jobmanager.bind-host: 0.0.0.0
jobmanager.memory.process.size: 2048m
taskmanager.bind-host: 0.0.0.0
taskmanager.memory.process.size: 6g
taskmanager.numberOfTaskSlots: 4
parallelism.default: 4
state.backend: filesystem                 # 使用文件系统作为状态后端（可选：rocksdb, filesystem）
state.checkpoints.dir: hdfs://hadoop-01:9000/flink_checkpoint  # Checkpoint 的存储路径
state.savepoints.dir: hdfs://hadoop-01:9000/flink_savepoint    # Savepoint 的存储路径
execution.checkpointing.interval: 60s
execution.checkpointing.mode: EXACTLY_ONCE
execution.checkpointing.tolerable-failed-checkpoints: 3
execution.checkpointing.max-concurrent-checkpoints: 1
restart-strategy: fixed-delay
restart-strategy.fixed-delay.attempts: 3
restart-strategy.fixed-delay.delay: 10s
jobmanager.execution.failover-strategy: region
rest.port: 8081
rest.address: hadoop-01
rest.bind-port: 8080-8090
rest.bind-address: 0.0.0.0
execution.target: yarn-session
yarn.application.id: application_1727256777158_0001
jobmanager.archive.fs.dir: hdfs://hadoop-01:9000/logs/flink-job
historyserver.web.address: 0.0.0.0
historyserver.web.port: 8082
classloader.check-leaked-classloader: false
env.java.opts: -Dfile.encoding=UTF-8
#作业归档保留时间
jobmanager.archive.expiration-time: 259200000