(fluss) branch main updated: [hotfix] Fix unstable testUnionReadLogTableFailover test (#1680)

[yuxia]

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

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new cf5d24edb [hotfix] Fix unstable testUnionReadLogTableFailover test 
(#1680)
cf5d24edb is described below

commit cf5d24edb4201e44856a5be5abf06238dbadba1a
Author: yuxia Luo <luoyu...@alumni.sjtu.edu.cn>
AuthorDate: Thu Sep 11 20:49:13 2025 +0800

    [hotfix] Fix unstable testUnionReadLogTableFailover test (#1680)
---
 .../lake/paimon/flink/FlinkUnionReadLogTableITCase.java    | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

diff --git 
a/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/flink/FlinkUnionReadLogTableITCase.java
 
b/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/flink/FlinkUnionReadLogTableITCase.java
index 80c6832b0..987bc0451 100644
--- 
a/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/flink/FlinkUnionReadLogTableITCase.java
+++ 
b/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/flink/FlinkUnionReadLogTableITCase.java
@@ -49,6 +49,7 @@ import java.util.stream.Collectors;
 
 import static 
org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.assertResultsExactOrder;
 import static 
org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.assertResultsIgnoreOrder;
+import static 
org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.assertRowResultsIgnoreOrder;
 import static org.apache.fluss.testutils.DataTestUtils.row;
 import static org.assertj.core.api.Assertions.assertThat;
 
@@ -205,7 +206,11 @@ class FlinkUnionReadLogTableITCase extends 
FlinkUnionReadTestBase {
 
         CloseableIterator<Row> actual =
                 streamTEnv.executeSql("select * from " + 
resultTableName).collect();
-        assertResultsExactOrder(actual, writtenRows, false);
+        if (isPartitioned) {
+            assertRowResultsIgnoreOrder(actual, writtenRows, false);
+        } else {
+            assertResultsExactOrder(actual, writtenRows, false);
+        }
 
         // now, stop the job with save point
         String savepointPath =
@@ -226,8 +231,11 @@ class FlinkUnionReadLogTableITCase extends 
FlinkUnionReadTestBase {
 
         // write some log data again
         List<Row> rows = writeRows(table1, 3, isPartitioned);
-
-        assertResultsExactOrder(actual, rows, true);
+        if (isPartitioned) {
+            assertRowResultsIgnoreOrder(actual, rows, true);
+        } else {
+            assertResultsExactOrder(actual, rows, true);
+        }
 
         // cancel jobs
         insertResult.getJobClient().get().cancel().get();