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 b2ebb57baaa3..167d56b4781a 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.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 {