????????????checkpoint????

[Robert.Zhang]

Hello all,
????????????????????iterative stream job 
????checkpoint??????????????????????????????????????checkpoint????????????
????state 
????????????k??????????????????????org.apache.flink.util.FlinkRuntimeException: 
Exceeded checkpoint tolerable failure threshold.??????


??????????
env.enableCheckpointing(10000, CheckpointingMode.EXACTLY_ONCE, true);
CheckpointConfig checkpointConfig = env.getCheckpointConfig();
checkpointConfig.setCheckpointTimeout(600000);
checkpointConfig.setMinPauseBetweenCheckpoints(60000);
checkpointConfig.setMaxConcurrentCheckpoints(4);
checkpointConfig.enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);
checkpointConfig.setPreferCheckpointForRecovery(true);
checkpointConfig.setTolerableCheckpointFailureNumber(2);
checkpointConfig.enableUnalignedCheckpoints();


??????????????????????????????????????????????????????????????