(incubator-paimon) branch master updated: [test] add time for cdc tests (#2532)

[lzljs3620320]

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 833e94f5e [test] add time for cdc tests (#2532)
833e94f5e is described below

commit 833e94f5eb2dd54186d5b2ae430a166a4827a149
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Tue Dec 19 13:10:39 2023 +0800

    [test] add time for cdc tests (#2532)
---
 .../paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java  | 2 +-
 .../apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkITCase.java    | 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/kafka/KafkaCanalSyncTableActionITCase.java
 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaCanalSyncTableActionITCase.java
index 62d87a733..85aa0b77b 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
@@ -704,7 +704,7 @@ public class KafkaCanalSyncTableActionITCase extends 
KafkaActionITCaseBase {
     }
 
     @Test
-    @Timeout(60)
+    @Timeout(120)
     public void testStarUpOptionLatest() throws Exception {
         final String topic = "start_up_latest";
         createTestTopic(topic, 1, 1);
diff --git 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkITCase.java
 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkITCase.java
index cfeaf0110..37f766c52 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkITCase.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkITCase.java
@@ -74,7 +74,7 @@ public class FlinkCdcSyncDatabaseSinkITCase extends 
AbstractTestBase {
     }
 
     @Test
-    @Timeout(120)
+    @Timeout(180)
     public void testRandomCdcEventsDynamicBucket() throws Exception {
         innerTestRandomCdcEvents(() -> -1);
     }