You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/04/05 06:48:37 UTC
[flink] branch master updated: [FLINK-27047][tests] Remove timeouts
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 3eb762bbf3a [FLINK-27047][tests] Remove timeouts
3eb762bbf3a is described below
commit 3eb762bbf3ae7fa1fe897300d4d12b3d22987e85
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Sun Apr 3 21:43:56 2022 +0200
[FLINK-27047][tests] Remove timeouts
There's no guarantee that the cleanup is initiated synchronously.
---
.../flink/runtime/dispatcher/DispatcherResourceCleanupTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 73cf51a7bf6..f007a82b5e1 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
@@ -526,14 +526,14 @@ public class DispatcherResourceCleanupTest extends TestLogger {
private void assertLocalCleanupTriggered(JobID jobId)
throws ExecutionException, InterruptedException, TimeoutException {
- assertThat(localCleanupFuture.get(100, TimeUnit.MILLISECONDS), equalTo(jobId));
+ assertThat(localCleanupFuture.get(), equalTo(jobId));
assertThat(globalCleanupFuture.isDone(), is(false));
}
private void assertGlobalCleanupTriggered(JobID jobId)
throws ExecutionException, InterruptedException, TimeoutException {
assertThat(localCleanupFuture.isDone(), is(false));
- assertThat(globalCleanupFuture.get(100, TimeUnit.MILLISECONDS), equalTo(jobId));
+ assertThat(globalCleanupFuture.get(), equalTo(jobId));
}
@Test