You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/08/14 14:55:42 UTC
[flink] 01/02: [FLINK-13585][tests] Harden TaskAsyncCallTest by
fixing race condition
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f5fb2c036e69870c45c3733fe5ea4ead1a52d918
Author: ifndef-SleePy <mm...@gmail.com>
AuthorDate: Wed Aug 14 20:46:52 2019 +0800
[FLINK-13585][tests] Harden TaskAsyncCallTest by fixing race condition
This closes #9436.
---
.../java/org/apache/flink/runtime/taskmanager/TaskAsyncCallTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskAsyncCallTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskAsyncCallTest.java
index f7b366b..ef1d816 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskAsyncCallTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskAsyncCallTest.java
@@ -196,9 +196,9 @@ public class TaskAsyncCallTest extends TestLogger {
triggerLatch.await();
task.notifyCheckpointComplete(1);
- task.cancelExecution();
-
notifyCheckpointCompleteLatch.await();
+
+ task.cancelExecution();
stopLatch.await();
assertThat(classLoaders, hasSize(greaterThanOrEqualTo(2)));