This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new e5ee6576cba [HUDI-5814] Disable flaky tests to unblock CI (#7986)
e5ee6576cba is described below
commit e5ee6576cba1c5346ba884d0807cf456cb2e0d97
Author: Y Ethan Guo <[email protected]>
AuthorDate: Thu Feb 16 18:11:13 2023 -0800
[HUDI-5814] Disable flaky tests to unblock CI (#7986)
This commit disables frequent flaky tests to unblock CI. HUDI-5815 is the
follow-up investigation ticket.
-
`TestHoodieDeltaStreamer.testHoodieAsyncClusteringJobWithScheduleAndExecute`
- `TestHoodieDeltaStreamer.testAsyncClusteringServiceWithCompaction`
- `TestHoodieDeltaStreamer.testUpsertsMORContinuousMode`
- `TestHoodieDeltaStreamer.testHoodieIndexer`
---
.../apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java
index c2073c703d9..03f8392511b 100644
---
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java
+++
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java
@@ -821,6 +821,7 @@ public class TestHoodieDeltaStreamer extends
HoodieDeltaStreamerTestBase {
testUpsertsContinuousMode(HoodieTableType.COPY_ON_WRITE, "continuous_cow",
true, recordType);
}
+ @Disabled("HUDI-5815 for investigation")
@ParameterizedTest
@EnumSource(value = HoodieRecordType.class, names = {"AVRO", "SPARK"})
public void testUpsertsMORContinuousMode(HoodieRecordType recordType) throws
Exception {
@@ -1154,6 +1155,7 @@ public class TestHoodieDeltaStreamer extends
HoodieDeltaStreamerTestBase {
return config;
}
+ @Disabled("HUDI-5815 for investigation")
@ParameterizedTest
@EnumSource(value = HoodieRecordType.class, names = {"AVRO", "SPARK"})
public void testHoodieIndexer(HoodieRecordType recordType) throws Exception {
@@ -1284,6 +1286,7 @@ public class TestHoodieDeltaStreamer extends
HoodieDeltaStreamerTestBase {
UtilitiesTestBase.Helpers.deleteFileFromDfs(fs, tableBasePath);
}
+ @Disabled("HUDI-5815 for investigation")
@ParameterizedTest
@EnumSource(value = HoodieRecordType.class, names = {"AVRO", "SPARK"})
public void testAsyncClusteringServiceWithCompaction(HoodieRecordType
recordType) throws Exception {
@@ -1359,6 +1362,7 @@ public class TestHoodieDeltaStreamer extends
HoodieDeltaStreamerTestBase {
UtilitiesTestBase.Helpers.deleteFileFromDfs(fs, tableBasePath);
}
+ @Disabled("HUDI-5815 for investigation")
@ParameterizedTest
@CsvSource(value = {"execute, AVRO", "schedule, AVRO", "scheduleAndExecute,
AVRO", "execute, SPARK", "schedule, SPARK", "scheduleAndExecute, SPARK"})
public void testHoodieAsyncClusteringJobWithScheduleAndExecute(String
runningMode, HoodieRecordType recordType) throws Exception {