[incubator-paimon] branch master updated: [test] Fix KafkaCanalSyncDatabaseActionITCase.testTableAffixOneTopic is not stable. (#1961)

[lz...@apache.org]

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/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 6e0cb56f1 [test] Fix KafkaCanalSyncDatabaseActionITCase.testTableAffixOneTopic is not stable. (#1961)
6e0cb56f1 is described below

commit 6e0cb56f1a2040f3c3ba984096eb8d63acf89c81
Author: Kerwin <37...@users.noreply.github.com>
AuthorDate: Thu Sep 7 21:55:15 2023 +0800

    [test] Fix KafkaCanalSyncDatabaseActionITCase.testTableAffixOneTopic is not stable. (#1961)
---
 .../flink/action/cdc/kafka/KafkaCanalSyncDatabaseActionITCase.java      | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncDatabaseActionITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncDatabaseActionITCase.java
index 3dd96fecd..30a50afe3 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncDatabaseActionITCase.java
+++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncDatabaseActionITCase.java
@@ -352,6 +352,8 @@ public class KafkaCanalSyncDatabaseActionITCase extends KafkaActionITCaseBase {
 
     private void testTableAffixImpl(List<String> topics, boolean writeOne, int fileCount)
             throws Exception {
+        waitingTables("test_prefix_t1_test_suffix", "test_prefix_t2_test_suffix");
+
         FileStoreTable table1 = getFileStoreTable("test_prefix_t1_test_suffix");
         FileStoreTable table2 = getFileStoreTable("test_prefix_t2_test_suffix");