[FLINK-21690] remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.12.2
• Fix Version/s: 1.13.0, 1.12.3
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Zhengqi Zhang
• Reporter: Zhengqi Zhang
• Created: 09/Mar/21 13:28
• Updated: 11/Mar/21 03:37
• Resolved: 11/Mar/21 03:37

Description

there is an extra setting of tolerableCheckpointFailureNumber in the constructor of CheckpointConfig.

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

 

 

Issue Links

• links to: GitHub Pull Request #15141