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 dc1da6713 [test] Disable FlinkCdcSyncDatabaseSinkITCase
dc1da6713 is described below

commit dc1da6713456df27da21d8b10d9bfe4b8bdcbb30
Author: Jingsong <[email protected]>
AuthorDate: Fri Feb 2 21:02:05 2024 +0800

    [test] Disable FlinkCdcSyncDatabaseSinkITCase
---
 .../apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkITCase.java  | 4 ++++
 1 file changed, 4 insertions(+)

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 b2ebb57ba..167d56b47 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
@@ -41,6 +41,7 @@ import org.apache.paimon.utils.TraceableFileIO;
 import org.apache.flink.api.common.restartstrategy.RestartStrategies;
 import org.apache.flink.streaming.api.datastream.DataStreamSource;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.io.TempDir;
@@ -63,18 +64,21 @@ public class FlinkCdcSyncDatabaseSinkITCase extends 
AbstractTestBase {
 
     @TempDir java.nio.file.Path tempDir;
 
+    @Disabled
     @Test
     @Timeout(120)
     public void testRandomCdcEvents() throws Exception {
         innerTestRandomCdcEvents(() -> ThreadLocalRandom.current().nextInt(5) 
+ 1, false);
     }
 
+    @Disabled
     @Test
     @Timeout(180)
     public void testRandomCdcEventsDynamicBucket() throws Exception {
         innerTestRandomCdcEvents(() -> -1, false);
     }
 
+    @Disabled
     @Test
     @Timeout(180)
     public void testRandomCdcEventsUnawareBucket() throws Exception {

Reply via email to