(paimon) branch master updated: [hotfix] Fix failed test KafkaCanalSyncTableActionITCase#testStarUpOptionLatest (#3154)

[czweng]

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

czweng 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 b0ff65ffe [hotfix] Fix failed test 
KafkaCanalSyncTableActionITCase#testStarUpOptionLatest (#3154)
b0ff65ffe is described below

commit b0ff65ffee867a9a7fea7bc5a6599da884d33913
Author: yuzelin <33053040+yuze...@users.noreply.github.com>
AuthorDate: Wed Apr 3 16:49:06 2024 +0800

    [hotfix] Fix failed test 
KafkaCanalSyncTableActionITCase#testStarUpOptionLatest (#3154)
    
    This closes #3154.
---
 .../paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java
 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java
index 5bde711c0..bb259cd0f 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java
@@ -667,6 +667,9 @@ public class KafkaCanalSyncTableActionITCase extends 
KafkaSyncTableActionITCase
                         .build();
         runActionWithDefaultEnv(action);
 
+        // wait task running to commit LATEST_OFFSET
+        Thread.sleep(5_000);
+
         writeRecordsToKafka(topic, 
"kafka/canal/table/startupmode/canal-data-2.txt");
 
         FileStoreTable table = getFileStoreTable(tableName);