????
------------------ ???????? ------------------ ??????: "Yun Tang"<myas...@live.com>; ????????: 2020??1??17??(??????) ????2:32 ??????: "user-zh@flink.apache.org"<user-zh@flink.apache.org>; ????: Re: ?????? ??????????checkpoint Hi ??????????????????env.enableCheckpoint????????????????checkpoint????????????????restart strategy????NoRestart????????????????failover???? ???? ???? ???? Outlook for Android<https://aka.ms/ghei36> ________________________________ From: sun <1392427...@qq.com> Sent: Friday, January 17, 2020 1:43:53 PM To: user-zh <user-zh@flink.apache.org> Subject: ?????? ??????????checkpoint ?????????????????????????????????????????? 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;????????&nbsp;------------------ ??????:&nbsp;"sysuke Lee"<sysuke...@gmail.com&gt;; ????????:&nbsp;2020??1??17??(??????) ????12:10 ??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;; ????:&nbsp;Re: ??????????checkpoint ????????????checkpoint?????????????????????????? sun <1392427...@qq.com&gt; ??2020??1??17?????? ????10:42?????? &gt; ??????????????????????????????????????checkpoint????????????????checkpoint??????????????????????????