[flink] branch master updated: [FLINK-21690][checkpoint] Remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig

[tangyun]

This is an automated email from the ASF dual-hosted git repository.

tangyun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new bfb1451  [FLINK-21690][checkpoint] Remove redundant 
tolerableCheckpointFailureNumber setting in CheckpointConfig
bfb1451 is described below

commit bfb1451c8b8451b8e5e9532781338bac90894be8
Author: zhangzhengqi3 <zhangzheng...@jd.com>
AuthorDate: Thu Mar 11 00:46:05 2021 +0800

    [FLINK-21690][checkpoint] Remove redundant tolerableCheckpointFailureNumber 
setting in CheckpointConfig
---
 .../org/apache/flink/streaming/api/environment/CheckpointConfig.java     | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java
index 966dd54..4ec6125 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java
@@ -146,7 +146,6 @@ public class CheckpointConfig implements 
java.io.Serializable {
         this.externalizedCheckpointCleanup = 
checkpointConfig.externalizedCheckpointCleanup;
         this.forceCheckpointing = checkpointConfig.forceCheckpointing;
         this.forceUnalignedCheckpoints = 
checkpointConfig.forceUnalignedCheckpoints;
-        this.tolerableCheckpointFailureNumber = 
checkpointConfig.tolerableCheckpointFailureNumber;
         this.storage = checkpointConfig.getCheckpointStorage();
     }