Skip to content

Commit 8ba0474

Browse files
authored
Sanitize logging in FanOutStreamingEngineWorkerHarness (#39029)
1 parent 63bcd3d commit 8ba0474

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarness.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -303,10 +303,13 @@ private synchronized void consumeWindmillWorkerEndpoints(WindmillEndpoints newWi
303303
}
304304

305305
LOG.info(
306-
"Consuming new endpoints: {}. previous metadata version: {}, current metadata version: {}, previous endpoint type: {}, current endpoint type: {}",
307-
newWindmillEndpoints,
306+
"Consuming new endpoints. previous metadata version: {}, current metadata version: {}, "
307+
+ "windmill endpoint count: {}, global data endpoint count: {}, "
308+
+ "previous endpoint type: {}, current endpoint type: {}",
308309
activeMetadataVersion,
309310
newWindmillEndpoints.version(),
311+
newWindmillEndpoints.windmillEndpoints().size(),
312+
newWindmillEndpoints.globalDataEndpoints().size(),
310313
activeMetadataType,
311314
newWindmillEndpoints.type());
312315
closeStreamsNotIn(newWindmillEndpoints).join();

0 commit comments

Comments
 (0)