[FLINK-33346][runtime][test] Removes timeout
The instability is caused by the timeout. The fatal error hides the actual cause (i.e. the TimeoutException). It can be reproduced by setting the timeout of the test to 0ms. The actual cause is revealed when disabling the fatal error handling or not throwing a AssertionError in case of the fatal error.
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java
index 286003f..ac46935 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java
@@ -566,9 +566,7 @@
final CompletableFuture<? extends Throwable> errorFuture =
this.testingFatalErrorHandlerResource.getFatalErrorHandler().getErrorFuture();
- assertThat(
- errorFuture.get(100, TimeUnit.MILLISECONDS),
- IsInstanceOf.instanceOf(FlinkException.class));
+ assertThat(errorFuture.get(), IsInstanceOf.instanceOf(FlinkException.class));
testingFatalErrorHandlerResource.getFatalErrorHandler().clearError();
}
