You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/08/05 09:34:41 UTC
[flink] 02/04: [hotfix][tests] Fix that InvokableBlockingInInvoke
can finish from spurious wakeups
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0578d4fb6950d30c3bf6cc2a3cac27fb7abcb115
Author: Gary Yao <ga...@apache.org>
AuthorDate: Wed Jul 31 16:47:29 2019 +0200
[hotfix][tests] Fix that InvokableBlockingInInvoke can finish from spurious wakeups
---
.../src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
index 167c988..ad5a23a 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
@@ -1063,7 +1063,9 @@ public class TaskTest extends TestLogger {
// block forever
synchronized (this) {
- wait();
+ while (true) {
+ wait();
+ }
}
}
}