Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
1.12.2
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; }
Attachments
Attachments
Issue Links
- links to