(paimon) branch master updated: [flink] Fix flaky AppendTableITCase streaming compaction tests (#10184)

[lzljs3620320]

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

JingsongLi 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 a9bc5ecf29 [flink] Fix flaky AppendTableITCase streaming compaction 
tests (#10184)
a9bc5ecf29 is described below

commit a9bc5ecf2919cc04c6328fd487a3f8e55c2d4576
Author: YangJie <yangji...@baidu.com>
AuthorDate: Mon Oct 5 10:15:29 2026 -0400

    [flink] Fix flaky AppendTableITCase streaming compaction tests (#10184)
---
 .../src/test/java/org/apache/paimon/flink/AppendTableITCase.java      | 2 +-
 .../src/test/java/org/apache/paimon/flink/AppendTableITCase.java      | 2 +-
 .../src/test/java/org/apache/paimon/flink/AppendTableITCase.java      | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
 
b/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
index f3b6dd051c..255855df71 100644
--- 
a/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
+++ 
b/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
@@ -52,7 +52,7 @@ public class AppendTableITCase extends CatalogITCaseBase {
                         + "    'rows-per-second' = '1'\n"
                         + ")");
 
-        assertStreamingHasCompact("INSERT INTO append_table SELECT * FROM 
Orders_in", 60000);
+        assertStreamingHasCompact("INSERT INTO append_table SELECT * FROM 
Orders_in", 300000);
         // ensure data gen finished
         Thread.sleep(5000);
     }
diff --git 
a/paimon-flink/paimon-flink-1.19/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
 
b/paimon-flink/paimon-flink-1.19/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
index f3b6dd051c..255855df71 100644
--- 
a/paimon-flink/paimon-flink-1.19/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
+++ 
b/paimon-flink/paimon-flink-1.19/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
@@ -52,7 +52,7 @@ public class AppendTableITCase extends CatalogITCaseBase {
                         + "    'rows-per-second' = '1'\n"
                         + ")");
 
-        assertStreamingHasCompact("INSERT INTO append_table SELECT * FROM 
Orders_in", 60000);
+        assertStreamingHasCompact("INSERT INTO append_table SELECT * FROM 
Orders_in", 300000);
         // ensure data gen finished
         Thread.sleep(5000);
     }
diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
index 4c535b6798..5ddeb6ecda 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/AppendTableITCase.java
@@ -316,7 +316,7 @@ public class AppendTableITCase extends CatalogITCaseBase {
                         + "    'rows-per-second' = '1'\n"
                         + ")");
 
-        assertStreamingHasCompact("INSERT INTO append_table SELECT * FROM 
Orders_in", 60000);
+        assertStreamingHasCompact("INSERT INTO append_table SELECT * FROM 
Orders_in", 300000);
         // ensure data gen finished
         Thread.sleep(5000);
     }
@@ -343,7 +343,7 @@ public class AppendTableITCase extends CatalogITCaseBase {
                         + "    'number-of-rows' = '10'\n"
                         + ")");
 
-        assertStreamingHasCompact("INSERT INTO append_table SELECT f0, f1 FROM 
Orders_in", 60000);
+        assertStreamingHasCompact("INSERT INTO append_table SELECT f0, f1 FROM 
Orders_in", 300000);
         // ensure data gen finished
         Thread.sleep(5000);