This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 05ee359ebd5 [FLINK-34206][test] Temporarily disable
CacheITCase#testRetryOnCorruptedClusterDataset
05ee359ebd5 is described below
commit 05ee359ebd564af3dd8ab31975cd479e92ba1785
Author: sunxia <[email protected]>
AuthorDate: Fri Jan 26 19:22:27 2024 +0800
[FLINK-34206][test] Temporarily disable
CacheITCase#testRetryOnCorruptedClusterDataset
This closes #24201.
---
.../test/java/org/apache/flink/test/streaming/runtime/CacheITCase.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/CacheITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/CacheITCase.java
index c60595de6b3..8866b205ce1 100644
---
a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/CacheITCase.java
+++
b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/CacheITCase.java
@@ -48,6 +48,7 @@ import org.apache.flink.util.OutputTag;
import org.apache.commons.io.FileUtils;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir;
@@ -217,6 +218,7 @@ public class CacheITCase extends AbstractTestBase {
}
@Test
+ @Disabled
void testRetryOnCorruptedClusterDataset(@TempDir java.nio.file.Path
tmpDir) throws Exception {
File file = prepareTestData(tmpDir);