(Forwarding this to the user mailing list as this mail is written in English)
Hi! I think problem 1 is the expected behavior. Is this behavior inconvenient for you? If yes why it is the case? For problem 2, could you explain in detail how do you run the word count program and where do you store the counting result? It might be that you're storing the results in a sink which only updates the result after a successful checkpoint. 王小宅的蜗居生活 <eric414664...@gmail.com> 于2021年10月12日周二 上午9:32写道： > The flink version is v1.13.2 > > 王小宅的蜗居生活 <eric414664...@gmail.com> 于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. > > >
