(paimon) branch master updated: [test] Fix unstable tests in MySqlSyncDatabaseTableListITCase (#4268)

[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 f39450137 [test] Fix unstable tests in 
MySqlSyncDatabaseTableListITCase (#4268)
f39450137 is described below

commit f39450137661f8f75fc154cea3f72587480d8033
Author: tsreaper <tsreape...@gmail.com>
AuthorDate: Thu Sep 26 22:07:07 2024 +0800

    [test] Fix unstable tests in MySqlSyncDatabaseTableListITCase (#4268)
---
 .../cdc/mysql/MySqlSyncDatabaseTableListITCase.java | 21 ++++++++++++++-------
 1 file changed, 14 insertions(+), 7 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseTableListITCase.java
 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseTableListITCase.java
index c15cbf898..21866a0a2 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseTableListITCase.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseTableListITCase.java
@@ -19,6 +19,7 @@
 package org.apache.paimon.flink.action.cdc.mysql;
 
 import org.apache.paimon.flink.action.MultiTablesSinkMode;
+import org.apache.paimon.table.FileStoreTable;
 import org.apache.paimon.types.DataType;
 import org.apache.paimon.types.DataTypes;
 import org.apache.paimon.types.RowType;
@@ -28,7 +29,9 @@ import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
 
 import java.sql.Statement;
+import java.util.Arrays;
 import java.util.Collections;
+import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ThreadLocalRandom;
 
@@ -45,7 +48,7 @@ public class MySqlSyncDatabaseTableListITCase extends 
MySqlActionITCaseBase {
     }
 
     @Test
-    @Timeout(180)
+    @Timeout(60)
     public void testActionRunResult() throws Exception {
         Map<String, String> mySqlConfig = getBasicMySqlConfig();
         mySqlConfig.put(
@@ -80,14 +83,18 @@ public class MySqlSyncDatabaseTableListITCase extends 
MySqlActionITCaseBase {
         // test newly created tables
         if (mode == COMBINED) {
             try (Statement statement = getStatement()) {
-                // ensure the job steps into incremental phase
-                waitForResult(
-                        Collections.singletonList("+I[1, A]"),
-                        getFileStoreTable("shard_1_t2"),
+                FileStoreTable t2 = getFileStoreTable("shard_1_t2");
+                RowType rowTypeT2 =
                         RowType.of(
                                 new DataType[] {DataTypes.INT().notNull(), 
DataTypes.VARCHAR(100)},
-                                new String[] {"k", "name"}),
-                        Collections.singletonList("k"));
+                                new String[] {"k", "name"});
+                List<String> primaryKeysT2 = Collections.singletonList("k");
+
+                // ensure the job steps into incremental phase
+                waitForResult(Collections.singletonList("+I[1, A]"), t2, 
rowTypeT2, primaryKeysT2);
+                statement.executeUpdate("USE shard_1");
+                statement.executeUpdate("INSERT INTO t2 VALUES (2, 'B')");
+                waitForResult(Arrays.asList("+I[1, A]", "+I[2, B]"), t2, 
rowTypeT2, primaryKeysT2);
 
                 // case 1: new tables in existed database
                 statement.executeUpdate("USE shard_2");