(beam) branch master updated: Sanitize logging in FanOutStreamingEngineWorkerHarness (#39029)

[scwhittle]

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

scwhittle 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 8ba04741b47 Sanitize logging in FanOutStreamingEngineWorkerHarness 
(#39029)
8ba04741b47 is described below

commit 8ba04741b47d0bed4ab0fb33dfdec495d8fe4fcf
Author: parveensania <san...@google.com>
AuthorDate: Fri Jun 19 00:42:28 2026 -0700

    Sanitize logging in FanOutStreamingEngineWorkerHarness (#39029)
---
 .../streaming/harness/FanOutStreamingEngineWorkerHarness.java      | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarness.java
 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarness.java
index 90a185973b8..f3262c17b69 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarness.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarness.java
@@ -303,10 +303,13 @@ public final class FanOutStreamingEngineWorkerHarness 
implements StreamingWorker
     }
 
     LOG.info(
-        "Consuming new endpoints: {}. previous metadata version: {}, current 
metadata version: {}, previous endpoint type: {}, current endpoint type: {}",
-        newWindmillEndpoints,
+        "Consuming new endpoints. previous metadata version: {}, current 
metadata version: {}, "
+            + "windmill endpoint count: {}, global data endpoint count: {}, "
+            + "previous endpoint type: {}, current endpoint type: {}",
         activeMetadataVersion,
         newWindmillEndpoints.version(),
+        newWindmillEndpoints.windmillEndpoints().size(),
+        newWindmillEndpoints.globalDataEndpoints().size(),
         activeMetadataType,
         newWindmillEndpoints.type());
     closeStreamsNotIn(newWindmillEndpoints).join();