generalize sanity check for tolerableCpFailureNumber to re-trigger tr…

…avis
apache · Jun 23, 2019 · 0e55b99 · 0e55b99
1 parent 2bdd142
commit 0e55b99
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java b/...main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java
@@ -19,13 +19,14 @@
 package org.apache.flink.runtime.jobgraph.tasks;
 
 import org.apache.flink.runtime.checkpoint.CheckpointCoordinator;
-import org.apache.flink.runtime.checkpoint.CheckpointFailureManager;
 import org.apache.flink.runtime.checkpoint.CheckpointRetentionPolicy;
 import org.apache.flink.util.Preconditions;
 
 import java.io.Serializable;
 import java.util.Objects;
 
+import static org.apache.flink.runtime.checkpoint.CheckpointFailureManager.UNDEFINED_TOLERABLE_CHECKPOINT_NUMBER;
+
 /**
  * Configuration settings for the {@link CheckpointCoordinator}. This includes the checkpoint
  * interval, the checkpoint timeout, the pause between checkpoints, the maximum number of
@@ -72,7 +73,7 @@ public CheckpointCoordinatorConfiguration(
 		// sanity checks
 		if (checkpointInterval < 10 || checkpointTimeout < 10 ||
 			minPauseBetweenCheckpoints < 0 || maxConcurrentCheckpoints < 1 ||
-			tolerableCpFailureNumber < CheckpointFailureManager.UNDEFINED_TOLERABLE_CHECKPOINT_NUMBER) {
+			(tolerableCpFailureNumber < 0 && tolerableCpFailureNumber != UNDEFINED_TOLERABLE_CHECKPOINT_NUMBER)) {
 			throw new IllegalArgumentException();
 		}