??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;
}
----
??:"LakeShen"
