The flink version is v1.13.2 王小宅的蜗居生活 <[email protected]> 于2021年10月11日周一 下午9:01写道：
> Use flink sql for real-time calculation (deployment mode: on yarn). To use > the checkpoint, you need to configure the following in the flink-conf.yaml: > > > state.backend: filesystem > > state.checkpoints.dir: hdfs:///flink/flink-checkpoints > > state.savepoints.dir: hdfs:///flink/flink-savepoints > > state.checkpoints.num-retained: 10 > > > There are two problems: > > 1.checkpoint generates a folder at the initial stage in the HDFS. > > 2. The savepoint cannot record the data status. > > For example: The simple wordcount cannot record the accumulated value. >
