[beam] branch master updated: Include ID and name of tracked thread in lull message (#29007)

[lostluck]

This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 68fec9e1ac6 Include ID and name of tracked thread in lull message 
(#29007)
68fec9e1ac6 is described below

commit 68fec9e1ac61eab8fff9c457f42251b2af1ee9bc
Author: Joar Wandborg <j...@wandborg.se>
AuthorDate: Sat Oct 21 19:33:57 2023 +0200

    Include ID and name of tracked thread in lull message (#29007)
    
    In order to aid debugging of lulls.
---
 .../beam/runners/dataflow/worker/DataflowOperationContext.java     | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java
 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java
index df520ebd392..b2ab928bc99 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java
@@ -264,7 +264,12 @@ public class DataflowOperationContext implements 
OperationContext {
           .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()));