Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21690

remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig

    XMLWordPrintableJSON

Details

    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

        1. image-2021-03-10-18-04-34-353.png
          317 kB
          Zhengqi Zhang

        Issue Links

          Activity

            People

              Tony Giao Zhengqi Zhang
              Tony Giao Zhengqi Zhang
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: