| commit | a2544aee733a52f204594b1bb3b8f712a3a48d59 | [log] [tgz] |
|---|---|---|
| author | Ismaël Mejía <iemejia@gmail.com> | Thu Jan 23 15:39:42 2020 +0100 |
| committer | GitHub <noreply@github.com> | Thu Jan 23 15:39:42 2020 +0100 |
| tree | fe8c40d6663da75d8c4f0314cabf57c671cfc83d | |
| parent | 5017e58a5d602d4202930f59aa02bbabde741acf [diff] | |
| parent | fd3da1e68f18560954f9c736146c7565e4a1af0f [diff] |
Merge pull request #10530: [BEAM-9065] Reset MetricsContainerStepMapAccumulator upon initialization of MetricsAccumulator singleton
diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/MetricsAccumulator.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/MetricsAccumulator.java index 2d83c3c..8313d73 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/MetricsAccumulator.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/MetricsAccumulator.java
@@ -74,6 +74,8 @@ } } LOG.info("Instantiated metrics accumulator: " + instance.value()); + } else { + instance.reset(); } }
diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/MetricsAccumulator.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/MetricsAccumulator.java index f674ef9..e182cf0 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/MetricsAccumulator.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/MetricsAccumulator.java
@@ -51,6 +51,8 @@ } } LOG.info("Instantiated metrics accumulator: " + instance.value()); + } else { + instance.reset(); } }