[test] Disable FlinkCdcSyncDatabaseSinkITCase

tongcheng-elong · Feb 2, 2024 · dc1da67 · dc1da67
1 parent f91a034
commit dc1da67
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...nk-cdc/src/test/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkITCase.java b/...nk-cdc/src/test/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkITCase.java
@@ -41,6 +41,7 @@
 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 {