[hotfix][checkpoint] Fix the wrong parameters due to base code change…

… in StreamTaskFinalCheckpointsTest
liuzidi · Dec 22, 2021 · f191bec · f191bec
1 parent e8bd52b
commit f191bec
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...rc/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskFinalCheckpointsTest.java b/...rc/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskFinalCheckpointsTest.java
@@ -884,7 +884,10 @@ public void testWaitingForUnalignedChannelStatesIfFinishedOnRestore() throws Exc
             checkpointResponder.setDeclinedLatch(new OneShotLatch());
 
             CheckpointBarrier unalignedBarrier =
-                    new CheckpointBarrier(2, 2, CheckpointOptions.unaligned(getDefault()));
+                    new CheckpointBarrier(
+                            2,
+                            2,
+                            CheckpointOptions.unaligned(CheckpointType.CHECKPOINT, getDefault()));
 
             // On first unaligned barrier, the task would take snapshot and start the asynchronous
             // part. We slightly extend the process to make the asynchronous part start executing