??????????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&gt;.
#
#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).&nbsp;
#
#state.backend.incremental: false