From 7ae9a2f477b59bd1632f779f7a8146e36b21cc3a Mon Sep 17 00:00:00 2001
From: Sania Parveen <saniap@google.com>
Date: Fri, 19 Jun 2026 03:10:11 +0000
Subject: [PATCH] Sanitize logging in FanOutStreamingEngineWorkerHarness

---
 .../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 90a185973b84..f3262c17b698 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 @@ private synchronized void consumeWindmillWorkerEndpoints(WindmillEndpoints newWi
     }
 
     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();