clmccart commented on code in PR #29592:
URL: https://github.com/apache/beam/pull/29592#discussion_r1416338439
##########
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java:
##########
@@ -245,6 +248,16 @@ public static class DataflowExecutionStateTracker extends
ExecutionStateTracker
private final ContextActivationObserverRegistry
contextActivationObserverRegistry;
private final String workItemId;
+ /**
+ * Metadata on the message whose processing is currently being managed by
this tracker. If no
+ * message is actively being processed, activeMessageMetadata will be null.
+ */
+ private ActiveMessageMetadata activeMessageMetadata = null;
Review Comment:
ef56c0419a649d246e0ee00e927ee821361be943
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
