From 9e65c4006dd4622d7d36eb2d0678f963898b3e5c Mon Sep 17 00:00:00 2001 From: Edward Cheng Date: Tue, 19 Sep 2023 00:10:32 +0000 Subject: [PATCH] revert format change straggler --- .../beam/runners/dataflow/worker/StreamingDataflowWorker.java | 1 - 1 file changed, 1 deletion(-) diff --git a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java index cee327d493e0..9844f30b3cc5 100644 --- a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java +++ b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java @@ -158,7 +158,6 @@ public class StreamingDataflowWorker { /** The idGenerator to generate unique id globally. */ private static final IdGenerator idGenerator = IdGenerators.decrementingLongs(); - /** * Fix up MapTask representation because MultiOutputInfos are missing from system generated * ParDoInstructions.