[jira] [Created] (FLINK-21690) remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig

["Zhengqi Zhang (Jira)" <ji...@apache.org>]

Zhengqi Zhang created FLINK-21690:
-------------------------------------

             Summary: remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig
                 Key: FLINK-21690
                 URL: https://issues.apache.org/jira/browse/FLINK-21690
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Checkpointing
    Affects Versions: 1.12.2
            Reporter: Zhengqi Zhang


there is an extra setting of tolerableCheckpointFailureNumber in the constructor of CheckpointConfig.
{code:java}
public CheckpointConfig(final CheckpointConfig checkpointConfig) {
    checkNotNull(checkpointConfig);

    this.checkpointInterval = checkpointConfig.checkpointInterval;
    this.checkpointingMode = checkpointConfig.checkpointingMode;
    this.checkpointTimeout = checkpointConfig.checkpointTimeout;
    this.maxConcurrentCheckpoints = checkpointConfig.maxConcurrentCheckpoints;
    this.minPauseBetweenCheckpoints = checkpointConfig.minPauseBetweenCheckpoints;
    this.preferCheckpointForRecovery = checkpointConfig.preferCheckpointForRecovery;
    this.tolerableCheckpointFailureNumber = checkpointConfig.tolerableCheckpointFailureNumber;
    this.unalignedCheckpointsEnabled = checkpointConfig.isUnalignedCheckpointsEnabled();
    this.alignmentTimeout = checkpointConfig.alignmentTimeout;
    this.approximateLocalRecovery = checkpointConfig.isApproximateLocalRecoveryEnabled();
    this.externalizedCheckpointCleanup = checkpointConfig.externalizedCheckpointCleanup;
    this.forceCheckpointing = checkpointConfig.forceCheckpointing;
    this.forceUnalignedCheckpoints = checkpointConfig.forceUnalignedCheckpoints;
    this.tolerableCheckpointFailureNumber = checkpointConfig.tolerableCheckpointFailureNumber;
}

{code}
 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)