Include ID and name of tracked thread in lull message (#29007)

In order to aid debugging of lulls.
apache · Oct 21, 2023 · 68fec9e · 68fec9e
1 parent 84c9ea0
commit 68fec9e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...orker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java b/...orker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java
@@ -264,7 +264,12 @@ protected String getLullMessage(Thread trackedThread, Duration lullDuration) {
           .append(" for at least ")
           .append(formatDuration(lullDuration))
           .append(" without outputting or completing in state ")
-          .append(getStateName());
+          .append(getStateName())
+          .append(" in thread ")
+          .append(trackedThread.getName())
+          .append(" with id ")
+          .append(trackedThread.getId());
+
       message.append("\n");
 
       message.append(getStackTraceForLullMessage(trackedThread.getStackTrace()));