邮件里你上传的图片没有显示； 你的配置文件里没有设置 checkpoint 相关的配置，你可以参照 Flink 官网的这里设置一下，也可以在代码里手动设置。
在 2020-06-01 16:46:11，"sun" <[email protected]> 写道： 用bin/flink run -n -c com.toonyoo.bi.flink.Application jar/ty-bi-flink-1.0-SNAPSHOT.jar --topic member启动topic 为什么checkpoint都是0啊，我的配置文件在下面。 # high-availability.zookeeper.client.acl: open #============================================================================== # Fault tolerance and checkpointing #============================================================================== # The backend that will be used to store operator state checkpoints if # checkpointing is enabled. # # Supported backends are 'jobmanager', 'filesystem', 'rocksdb', or the # <class-name-of-factory>. # #state.backend: filesystem # Directory for checkpoints filesystem, when using any of the default bundled # state backends. # #state.checkpoints.dir: file:///opt/flink/flink-1.7.2/checkpoints # Default target directory for savepoints, optional. # #state.savepoints.dir: file:///opt/flink/flink-1.7.2/savepoints # Flag to enable/disable incremental checkpoints for backends that # support incremental checkpoints (like the RocksDB state backend). # #state.backend.incremental: false
