| 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 |