(paimon) branch master updated: [hotfix] fix the unreliability test of AlignedSourceReaderTest#testCheckpointTrigger. (#5194)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new ca52728439 [hotfix] fix the unreliability test of 
AlignedSourceReaderTest#testCheckpointTrigger. (#5194)
ca52728439 is described below

commit ca52728439ed8dcfb8373bc38425b8fcb08bd167
Author: liming.1018 <liming.1...@bytedance.com>
AuthorDate: Mon Mar 3 13:06:14 2025 +0800

    [hotfix] fix the unreliability test of 
AlignedSourceReaderTest#testCheckpointTrigger. (#5194)
---
 .../org/apache/paimon/flink/source/align/AlignedSourceReaderTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
index a57058507d..d0a4e497dc 100644
--- 
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 class AlignedSourceReaderTest extends 
FileStoreSourceReaderTest {
 
             while (sourceReader.getNumberOfCurrentlyAssignedSplits() > 0
                     || inputProcessor.isAvailable()) {
-                testHarness.processSingleStep();
+                testHarness.processAll();
             }
 
             if (!rpcFirst) {