[FLINK-22105][tests] Fix checkpoint id in testForceAlignedCheckpointR…

…esultingInPriorityEvents
todd5167 · Apr 7, 2021 · 21c8450 · 21c8450
1 parent 61b8c55
commit 21c8450
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/.../test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java b/.../test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java
@@ -180,6 +180,7 @@ public void broadcastEvent(AbstractEvent event, boolean isPriorityEvent)
 
     @Test
     public void testForceAlignedCheckpointResultingInPriorityEvents() throws Exception {
+        final long checkpointId = 42L;
         MockEnvironment mockEnvironment = MockEnvironment.builder().build();
 
         SubtaskCheckpointCoordinator coordinator =
@@ -202,18 +203,18 @@ public void broadcastEvent(AbstractEvent event, boolean isPriorityEvent)
                         coordinator
                                 .getChannelStateWriter()
                                 .addOutputData(
-                                        0,
+                                        checkpointId,
                                         new ResultSubpartitionInfo(0, 0),
                                         0,
-                                        BufferBuilderTestUtils.buildSomeBuffer(1337));
+                                        BufferBuilderTestUtils.buildSomeBuffer(500));
                     }
                 };
 
         CheckpointOptions forcedAlignedOptions =
                 CheckpointOptions.unaligned(CheckpointStorageLocationReference.getDefault())
                         .withUnalignedUnsupported();
         coordinator.checkpointState(
-                new CheckpointMetaData(42, 0),
+                new CheckpointMetaData(checkpointId, 0),
                 forcedAlignedOptions,
                 new CheckpointMetricsBuilder(),
                 operatorChain,