邮件里你上传的图片没有显示;
你的配置文件里没有设置 checkpoint 相关的配置,你可以参照 Flink 官网的这里设置一下,也可以在代码里手动设置。
在 2020-06-01 16:46:11,"sun" <
[hidden email]> 写道:
用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