[FLINK-21104][task] Ease debugging.

usairman82 · Jan 30, 2021 · 393f64f · 393f64f
1 parent a6b909c
commit 393f64f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.java b/...-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.java
@@ -32,6 +32,7 @@
 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 Optional<Mail> tryTake(int priority) {
         try {
             Mail headMail;
             while ((headMail = takeOrNull(queue, priority)) == null) {
-                notEmpty.await();
+                // to ease debugging
+                notEmpty.await(1, TimeUnit.SECONDS);
             }
             hasNewMail = !queue.isEmpty();
             return headMail;