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

[sun]

????


------------------ ???????? ------------------
??????:&nbsp;"Yun Tang"<myas...@live.com&gt;;
????????:&nbsp;2020??1??17??(??????) ????2:32
??????:&nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&gt;;

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



Hi

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

????
????

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

________________________________
From: sun <1392427...@qq.com&gt;
Sent: Friday, January 17, 2020 1:43:53 PM
To: user-zh <user-zh@flink.apache.org&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"<sysuke...@gmail.com&amp;gt;;
????????:&amp;nbsp;2020??1??17??(??????) ????12:10
??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;

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



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

sun <1392427...@qq.com&amp;gt; ??2020??1??17?????? ????10:42??????

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