[hotfix] Fix failed test KafkaCanalSyncTableActionITCase#testStarUpOp…

…tionLatest (#3154) This closes #3154.
apache · Apr 3, 2024 · b0ff65f · b0ff65f
1 parent c915a40
commit b0ff65f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...c/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java b/...c/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java
@@ -667,6 +667,9 @@ public void testStarUpOptionLatest() throws Exception {
                         .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);