env.getCheckpointConfig().setFailOnCheckpointingErrors(failOnCheckpointingErrors); | env.getCheckpointConfig().setTolerableCheckpointFailureNumber(tolerableDeclinedCheckpointNumber); | env.getCheckpointConfig().setFailOnCheckpointingErrors(failOnCheckpointingErrors) | env.getCheckpointConfig().setTolerableCheckpointFailureNumber(failOnCheckpointingErrors) | flink | b760d556ca3757f3d0d1b8c81e5182b1bcc3dba3 | org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | | _1 | failOnCheckpointingErrors |
---|
_2 | tolerableDeclinedCheckpointNumber |
---|
| TCIVar | failOnCheckpointingErrors |
---|
v0 | env.getCheckpointConfig() |
---|
| | TCIVar | failOnCheckpointingErrors |
---|
v0 | env.getCheckpointConfig() |
---|
| Uses | True |