[cdc] Fix unstable MySqlSyncDatabaseTableListITCase (#2508)

apache · Dec 14, 2023 · 9aca98c · 9aca98c
1 parent c9ef520
commit 9aca98c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/.../test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseTableListITCase.java b/.../test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseTableListITCase.java
@@ -81,8 +81,6 @@ public void testActionRunResult() throws Exception {
         if (mode == COMBINED) {
             try (Statement statement = getStatement()) {
                 // ensure the job steps into incremental phase
-                statement.executeUpdate("USE shard_1");
-                statement.executeUpdate("INSERT INTO t2 VALUES (1, 'A')");
                 waitForResult(
                         Collections.singletonList("+I[1, A]"),
                         getFileStoreTable("shard_1_t2"),

diff --git a/paimon-flink/paimon-flink-cdc/src/test/resources/mysql/tablelist_test_setup.sql b/paimon-flink/paimon-flink-cdc/src/test/resources/mysql/tablelist_test_setup.sql
@@ -47,6 +47,8 @@ CREATE TABLE s2 (k INT, name VARCHAR(100), PRIMARY KEY (k)); -- captured
 CREATE TABLE sa (k INT, name VARCHAR(100), PRIMARY KEY (k)); -- ignored
 CREATE TABLE m (k INT, name VARCHAR(100), PRIMARY KEY (k)); -- ignored
 
+INSERT INTO t2 VALUES (1, 'A');
+
 USE shard_2;
 
 CREATE TABLE t1 (k INT, name VARCHAR(100), PRIMARY KEY (k)); -- captured