[hotfix][checkpointing] Fix the invalid argument in constuctor of Che…

…ckpointCoordinatorConfiguration
is · May 16, 2020 · 909a13d · 909a13d
1 parent 084b4b2
commit 909a13d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java b/...main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.runtime.jobgraph.tasks;
 
+import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.runtime.checkpoint.CheckpointCoordinator;
 import org.apache.flink.runtime.checkpoint.CheckpointRetentionPolicy;
 import org.apache.flink.util.Preconditions;
@@ -66,6 +67,7 @@ public class CheckpointCoordinatorConfiguration implements Serializable {
  * @deprecated use {@link #builder()}.
  */
  @Deprecated
+ @VisibleForTesting
  public CheckpointCoordinatorConfiguration(
  long checkpointInterval,
  long checkpointTimeout,
@@ -85,7 +87,7 @@ public CheckpointCoordinatorConfiguration(
  isExactlyOnce,
  isPreferCheckpointForRecovery,
  tolerableCpFailureNumber,
- false);
+ isUnalignedCheckpoint);
  }
 
  private CheckpointCoordinatorConfiguration(