[flink] branch master updated: [FLINK-24472][tests] Wait for cancellation future to complete

[ch...@apache.org]

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 e38cd1b  [FLINK-24472][tests] Wait for cancellation future to complete
e38cd1b is described below

commit e38cd1be718a207125e8116667d3e2675258d2b9
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu Oct 7 13:53:19 2021 +0200

    [FLINK-24472][tests] Wait for cancellation future to complete
---
 .../java/org/apache/flink/runtime/dispatcher/DispatcherTest.java     | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
index 10dcbe9..a2887c4 100755
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
@@ -99,6 +99,7 @@ import java.net.URISyntaxException;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -441,8 +442,8 @@ public class DispatcherTest extends AbstractDispatcherTest {
 
         assertThat(
                 cancelFuture,
-                FlinkMatchers.futureFailedWith(
-                        FlinkJobTerminatedWithoutCancellationException.class));
+                FlinkMatchers.futureWillCompleteExceptionally(
+                        FlinkJobTerminatedWithoutCancellationException.class, Duration.ofHours(8)));
     }
 
     @Test