You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2021/02/01 17:01:26 UTC
[flink] 02/07: [FLINK-21104][task] Ease debugging.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b9b682227b67b15199ab21a466735d44b142d54d
Author: Arvid Heise <ar...@ververica.com>
AuthorDate: Tue Jan 26 15:56:11 2021 +0100
[FLINK-21104][task] Ease debugging.
---
.../apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.java
index 118af3f..1389ea3 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.java
@@ -32,6 +32,7 @@ import java.util.Deque;
import java.util.Iterator;
import java.util.List;
import java.util.Optional;
+import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
@@ -133,7 +134,8 @@ public class TaskMailboxImpl implements TaskMailbox {
try {
Mail headMail;
while ((headMail = takeOrNull(queue, priority)) == null) {
- notEmpty.await();
+ // to ease debugging
+ notEmpty.await(1, TimeUnit.SECONDS);
}
hasNewMail = !queue.isEmpty();
return headMail;