(incubator-paimon) branch master updated: [cdc] Fix unstable MySqlSyncDatabaseTableListITCase (#2508)

[yuzelin]

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

yuzelin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 9aca98c70 [cdc] Fix unstable MySqlSyncDatabaseTableListITCase (#2508)
9aca98c70 is described below

commit 9aca98c7076b9dc6aa7818298b2259809a9f6c6e
Author: yuzelin <33053040+yuze...@users.noreply.github.com>
AuthorDate: Thu Dec 14 14:40:39 2023 +0800

    [cdc] Fix unstable MySqlSyncDatabaseTableListITCase (#2508)
---
 .../paimon/flink/action/cdc/mysql/MySqlSyncDatabaseTableListITCase.java | 2 --
 .../paimon-flink-cdc/src/test/resources/mysql/tablelist_test_setup.sql  | 2 ++
 2 files changed, 2 insertions(+), 2 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 0af24a42f..816b7b903 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
@@ -81,8 +81,6 @@ public class MySqlSyncDatabaseTableListITCase extends 
MySqlActionITCaseBase {
         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
index ea49883dd..d6af7682b 100644
--- 
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