用命令启动job

classic Classic list List threaded Threaded
2 messages Options
sun
Reply | Threaded
Open this post in threaded view
|

用命令启动job

sun
用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



Reply | Threaded
Open this post in threaded view
|

Re:用命令启动job

chaojianok
邮件里你上传的图片没有显示;
你的配置文件里没有设置 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