failOnCheckpointingErrors = pt.getBoolean(ENVIRONMENT_FAIL_ON_CHECKPOINTING_ERRORS.key(),ENVIRONMENT_FAIL_ON_CHECKPOINTING_ERRORS.defaultValue()) | tolerableDeclinedCheckpointNumber = pt.getInt(ENVIRONMENT_TOLERABLE_DECLINED_CHECKPOINT_NUMBER.key(),ENVIRONMENT_TOLERABLE_DECLINED_CHECKPOINT_NUMBER.defaultValue()) | pt.getBoolean(ENVIRONMENT_FAIL_ON_CHECKPOINTING_ERRORS.key(),ENVIRONMENT_FAIL_ON_CHECKPOINTING_ERRORS.defaultValue()) | pt.getInt(ENVIRONMENT_TOLERABLE_DECLINED_CHECKPOINT_NUMBER.key(),ENVIRONMENT_TOLERABLE_DECLINED_CHECKPOINT_NUMBER.defaultValue()) | flink | b760d556ca3757f3d0d1b8c81e5182b1bcc3dba3 | org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | | _1 | failOnCheckpointingErrors |
---|
_2 | tolerableDeclinedCheckpointNumber |
---|
| | | | AssignedTo | True |