1. state.checkpoints.num-retained 设置保存checkpoint的数量。
2. 因为你写的本地文件,所以JM侧的集群是否只在checkpoint的metadata信息,而其他机器上保存着具体的state状态



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复