You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by sun <13...@qq.com> on 2020/06/01 08:46:11 UTC
用命令启动job
用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
Re:用命令启动job
Posted by chaojianok <ch...@163.com>.
邮件里你上传的图片没有显示；
你的配置文件里没有设置 checkpoint 相关的配置，你可以参照 Flink 官网的这里设置一下，也可以在代码里手动设置。
在 2020-06-01 16:46:11，"sun" <13...@qq.com> 写道：
用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