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 {