remove unused field (#31293)

apache · May 27, 2024 · e764fc9 · e764fc9
1 parent 2719ca7
commit e764fc9
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/...worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java b/...worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java
@@ -31,7 +31,6 @@
 import java.util.Optional;
 import java.util.Random;
 import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
@@ -210,8 +209,6 @@ public class StreamingDataflowWorker {
   private final long clientId;
   private final MetricTrackingWindmillServerStub metricTrackingWindmillServer;
 
-  private final java.util.concurrent.ConcurrentLinkedQueue<CounterUpdate> pendingMonitoringInfos =
-      new ConcurrentLinkedQueue<>();
   // Map from stage name to StageInfo containing metrics container registry and per stage counters.
   private final ConcurrentMap<String, StageInfo> stageInfoMap;
 
@@ -1218,9 +1215,6 @@ private void process(
         LOG.error(e.toString());
       }
 
-      Iterables.addAll(
-          this.pendingMonitoringInfos, executionState.workExecutor().extractMetricUpdates());
-
       commitCallbacks.putAll(executionState.context().flushState());
 
       // Release the execution state for another thread to use.