[hotfix] fix the unreliability test of AlignedSourceReaderTest#testCheckpointTrigger.

liming30 · liming30 · commit 80af13d29da3 · 2025-03-03T11:48:43.000+08:00
diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/source/align/AlignedSourceReaderTest.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/source/align/AlignedSourceReaderTest.java
@@ -173,7 +173,7 @@ public void testCheckpointTrigger(boolean rpcFirst) throws Exception {
 
             while (sourceReader.getNumberOfCurrentlyAssignedSplits() > 0
                     || inputProcessor.isAvailable()) {
-                testHarness.processSingleStep();
+                testHarness.processAll();
             }
 
             if (!rpcFirst) {

Original file line number	Diff line number	Diff line change
`@@ -173,7 +173,7 @@ public void testCheckpointTrigger(boolean rpcFirst) throws Exception {`
`173`	`173`
`174`	`174`	`while (sourceReader.getNumberOfCurrentlyAssignedSplits() > 0`
`175`	`175`	`\|\| inputProcessor.isAvailable()) {`
`176`		`- testHarness.processSingleStep();`
	`176`	`+ testHarness.processAll();`
`177`	`177`	`}`
`178`	`178`
`179`	`179`	`if (!rpcFirst) {`