?????? flink???????????????? flink last checkpoint ???????????????????????????? state ??????????????

[cs]

??????????????????????checkpoint??????????????????
StreamExecutionEnvironment.getCheckpointConfig().setFailOnCheckpointingErrors(true);
/**
 * Sets the expected behaviour for tasks in case that they encounter an error 
in their checkpointing procedure.
 * If this is set to true, the task will fail on checkpointing error. If this 
is set to false, the task will only
 * decline a the checkpoint and continue running. The default is true.
 */
public void setFailOnCheckpointingErrors(boolean failOnCheckpointingErrors) {
   this.failOnCheckpointingErrors = failOnCheckpointingErrors;
}


------------------ ???????? ------------------
??????:&nbsp;"LakeShen"<shenleifight...@gmail.com&gt;;
????????:&nbsp;2020??6??23??(??????) ????7:48
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: flink???????????????? flink last checkpoint 
???????????????????????????? state ??????????????



Hi ,

???? Congxian ???????? Flink ???????????????????????????????????? Checkpoint 
??????????

???????????? last checkpoint ????????????????????????

Best,
LakeShen

Congxian Qiu <qcx978132...@gmail.com&gt; ??2020??6??22?????? ????8:23??????

&gt; hi
&gt;
&gt; ???????? state ????????????????????checkpoint ?????????????? state 
?????????????????????? checkpoint??
&gt;
&gt; Best,
&gt; Congxian
&gt;
&gt;
&gt; ???????? <xiaoxiong....@qq.com&gt; ??2020??6??22?????? ????8:09??????
&gt;
&gt; &gt; ??????????????flink?????????? 
??????????checkpoint????????????????????????&amp;nbsp;&amp;nbsp;
&gt;