This is an automated email from the ASF dual-hosted git repository. zhangyue19921010 pushed a commit to branch partition-bucket-index in repository https://gitbox.apache.org/repos/asf/hudi.git
commit aee3b4b0d0136298c51a4a1fca758be798f26d17 Author: Y Ethan Guo <[email protected]> AuthorDate: Tue Mar 18 18:53:07 2025 -0700 [HUDI-9196] Disable flaky tests on Flink (#12994) --- .../src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java | 2 ++ .../src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java index 2837f0ecd3c..41912c4f84e 100644 --- a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java +++ b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java @@ -63,6 +63,7 @@ import org.apache.flink.table.data.GenericRowData; import org.apache.flink.table.data.RowData; import org.apache.flink.table.types.logical.RowType; import org.apache.flink.util.TestLogger; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.io.TempDir; @@ -185,6 +186,7 @@ public class ITTestDataStreamWrite extends TestLogger { writeWithClusterAndCheckExpected(conf, "cow_write_with_cluster", 1, EXPECTED); } + @Disabled("HUDI-9196") @ParameterizedTest @ValueSource(strings = {"COPY_ON_WRITE", "MERGE_ON_READ"}) public void testStreamWriteWithIndexBootstrap(String tableType) throws Exception { diff --git a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java index 615141fffa7..352826025f7 100644 --- a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java +++ b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java @@ -1618,6 +1618,7 @@ public class ITTestHoodieDataSource { assertRowsEquals(result2.subList(result2.size() - 2, result2.size()), "[-U[1], +U[2]]"); } + @Disabled("HUDI-9196") @ParameterizedTest @EnumSource(value = HoodieTableType.class) void testIncrementalReadArchivedCommits(HoodieTableType tableType) throws Exception { @@ -2301,6 +2302,7 @@ public class ITTestHoodieDataSource { } + @Disabled("HUDI-9196") @ParameterizedTest @MethodSource("tableTypeAndBooleanTrueFalseParams") void testDynamicPartitionPrune(HoodieTableType tableType, boolean hiveStylePartitioning) throws Exception {
