研究flinkcheckpoint2

 //设置两个Checkpoint 之间最少等待时间,
 //如设置Checkpoint之间最少是要等 500ms(
 //为了避免每隔1000ms做一次Checkpoint的时候,前一次太慢和后一次重叠到一起去了)
//如:高速公路上,每隔1s关口放行一辆车,但是规定了两车之前的最小车距为500m
env.getCheckpointConfig().setMinPauseBetweenCheckpoints(500);//默认是0

//设置如果在做Checkpoint过程中出现错误，是否让整体任务失败：true是  false不是
env.getCheckpointConfig().setFailOnCheckpointingErrors(false);//默认是true
 
//设置是否清理检查点,
表示 Cancel 时是否需要保留当前的 Checkpoint，
默认 Checkpoint会在作业被Cancel时被删除
//ExternalizedCheckpointCleanup.DELETE_ON_CANCELLATION：true,
//当作业被取消时，删除外部的checkpoint(默认值)
//ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION：false,
//当作业被取消时，保留外部的checkpoint
env.getCheckpointConfig().
enableExternalizedCheckpoints(
CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);