flink版本是1.11,checkpoint配置是:

pipeline.time-characteristic EventTime
execution.checkpointing.interval 600000
execution.checkpointing.min-pause 120000
execution.checkpointing.timeout 120000
execution.checkpointing.externalized-checkpoint-retention
RETAIN_ON_CANCELLATION
state.backend rocksdb
state.backend.incremental true
state.checkpoints.dir hdfs:///tmp/flink/checkpoint

完整的jm log很大,1g多,上面贴的是关键的错误信息



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Reply via email to