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

Fri, 17 Jan 2020 00:06:21 -0800 

????


------------------ ???????? ------------------
??????:&nbsp;"Yun Tang"<[email protected]&gt;;
????????:&nbsp;2020??1??17??(??????) ????2:32
??????:&nbsp;"[email protected]"<[email protected]&gt;;

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



Hi

??????????????????env.enableCheckpoint????????????????checkpoint????????????????restart
 strategy????NoRestart????????????????failover????

????
????

???? Outlook for Android<https://aka.ms/ghei36&gt;

________________________________
From: sun <[email protected]&gt;
Sent: Friday, January 17, 2020 1:43:53 PM
To: user-zh <[email protected]&gt;
Subject: ?????? ??????????checkpoint

??????????????????????????????????????????
env.enableCheckpointing(CommonConstants.CHECK_POINTING);
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);
env.setParallelism(CommonConstants.PARALLELISM_NUMBER);
//????????????????
env.setRestartStrategy(RestartStrategies.noRestart());
//????????????????????????????????????????????????&nbsp; ???? 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);




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

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



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

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

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

回复