(paimon) branch master updated: [flink-cdc] Stabilize MySqlSyncDatabaseActionITCase.testSyncMultipleShards (#8736)

[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 6596efd10c [flink-cdc] Stabilize 
MySqlSyncDatabaseActionITCase.testSyncMultipleShards (#8736)
6596efd10c is described below

commit 6596efd10c66bd7b1353008e5710947317065fdf
Author: Vova Kolmakov <wombatu...@gmail.com>
AuthorDate: Mon Jul 20 10:29:34 2026 +0700

    [flink-cdc] Stabilize MySqlSyncDatabaseActionITCase.testSyncMultipleShards 
(#8736)
---
 .../flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java     | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java
 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java
index 042b4ddbcf..87d276aec8 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java
@@ -983,7 +983,7 @@ public class MySqlSyncDatabaseActionITCase extends 
MySqlActionITCaseBase {
     }
 
     @Test
-    @Timeout(120)
+    @Timeout(240)
     public void testSyncMultipleShards() throws Exception {
         Map<String, String> mySqlConfig = getBasicMySqlConfig();
 
@@ -1000,7 +1000,7 @@ public class MySqlSyncDatabaseActionITCase extends 
MySqlActionITCaseBase {
                         .withTableConfig(getBasicTableConfig())
                         .withMode(mode.configString())
                         .build();
-        runActionWithDefaultEnv(action);
+        JobClient client = runActionWithDefaultEnv(action);
 
         try (Statement statement = getStatement()) {
             // test insert into t1
@@ -1018,6 +1018,7 @@ public class MySqlSyncDatabaseActionITCase extends 
MySqlActionITCaseBase {
                             },
                             new String[] {"k", "v1", "v2"});
             waitForResult(
+                    client,
                     Arrays.asList(
                             "+I[1, db1_1, NULL]",
                             "+I[2, db1_2, NULL]",
@@ -1045,6 +1046,7 @@ public class MySqlSyncDatabaseActionITCase extends 
MySqlActionITCaseBase {
                             },
                             new String[] {"k", "v1", "v2", "v3"});
             waitForResult(
+                    client,
                     Arrays.asList(
                             "+I[1, 1.1, 1, NULL]",
                             "+I[2, 2.2, 2, NULL]",
@@ -1065,6 +1067,7 @@ public class MySqlSyncDatabaseActionITCase extends 
MySqlActionITCaseBase {
                             new DataType[] {DataTypes.INT().notNull(), 
DataTypes.VARCHAR(10)},
                             new String[] {"k", "v1"});
             waitForResult(
+                    client,
                     Arrays.asList("+I[3, db1_3]", "+I[4, db1_4]"),
                     table,
                     rowType,
@@ -1088,6 +1091,7 @@ public class MySqlSyncDatabaseActionITCase extends 
MySqlActionITCaseBase {
                                 new DataType[] {DataTypes.INT().notNull(), 
DataTypes.VARCHAR(10)},
                                 new String[] {"k", "v1"});
                 waitForResult(
+                        client,
                         Arrays.asList("+I[1, db1_1]", "+I[2, db2_2]"),
                         table,
                         rowType,