Address PR comments

apache · Jan 17, 2019 · a484f86 · a484f86
1 parent 2359de8
commit a484f86
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/...va/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkItemStatusClient.java b/...va/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkItemStatusClient.java
@@ -292,7 +292,6 @@ synchronized void populateCounterUpdates(WorkItemStatus status) {
     // User metrics reported in Worker
     extractMetrics(isFinalUpdate).forEach(appendCounterUpdate);
 
-    // counterUpdatesListBuilder.addAll(extractMetrics(isFinalUpdate));
     // MSec counters reported in worker
     extractMsecCounters(isFinalUpdate).forEach(appendCounterUpdate);
 

diff --git a/...c/main/java/org/apache/beam/runners/dataflow/worker/fn/control/BeamFnMapTaskExecutor.java b/...c/main/java/org/apache/beam/runners/dataflow/worker/fn/control/BeamFnMapTaskExecutor.java
@@ -505,7 +505,6 @@ public void stop() {
       // Set final metrics to precisely the values in this update. This should overwrite, not
       // be combined with, all prior updates.
       counterUpdates.clear();
-
       deprecatedCounterUpdates.clear();
       deprecatedDistributionUpdates.clear();
       deprecatedGaugeUpdates.clear();