diff --git a/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java b/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java index eb37e307c814..c5ae461425c1 100644 --- a/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java +++ b/flink/src/test/java/org/apache/iceberg/flink/TestFlinkTableSink.java @@ -43,6 +43,7 @@ import org.junit.Assume; import org.junit.Before; import org.junit.ClassRule; +import org.junit.Ignore; import org.junit.Test; import org.junit.rules.TemporaryFolder; import org.junit.runner.RunWith; @@ -245,6 +246,7 @@ public void testInsertIntoPartition() throws Exception { } @Test + @Ignore public void testHashDistributeMode() throws Exception { String tableName = "test_hash_distribution_mode"; Map tableProps = ImmutableMap.of(