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

Thu, 16 Jan 2020 21:44:55 -0800 

??????????????????????????????????????????
env.enableCheckpointing(CommonConstants.CHECK_POINTING);
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);
env.setParallelism(CommonConstants.PARALLELISM_NUMBER);
//????????????????
env.setRestartStrategy(RestartStrategies.noRestart());
//????????????????????????????????????????????????  ???? 10 ????
env.getCheckpointConfig().setCheckpointTimeout(CommonConstants.CHECK_POINT_TIME_OUT);
//??????????true??????????????????????????
env.getCheckpointConfig().setFailOnCheckpointingErrors(CommonConstants.FAIL_ON_CHECK_POINT);
env.getCheckpointConfig().setMaxConcurrentCheckpoints(CommonConstants.MAX_CHECK_POINTS);
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);




------------------ ???????? ------------------
??????:&nbsp;"sysuke Lee"<[email protected]&gt;;
????????:&nbsp;2020??1??17??(??????) ????12:10
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: ??????????checkpoint



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

sun <[email protected]&gt; ??2020??1??17?????? ????10:42??????

&gt; 
??????????????????????????????????????checkpoint????????????????checkpoint??????????????????????????

回复