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