APEX-117 #resolve metrics aggregation triggered within app window
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/77e693c2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/77e693c2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/77e693c2 Branch: refs/heads/feature-module Commit: 77e693c26962f90803b87212a512bfc3dd03c96b Parents: 760039e Author: Chandni Singh <[email protected]> Authored: Mon Sep 14 00:41:32 2015 -0700 Committer: Chandni Singh <[email protected]> Committed: Mon Sep 14 11:40:20 2015 -0700 ---------------------------------------------------------------------- .../java/com/datatorrent/stram/StreamingContainerManager.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/77e693c2/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java index 41738f4..6f36be6 100644 --- a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java +++ b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java @@ -842,6 +842,10 @@ public class StreamingContainerManager implements PlanContext metricPool.add(physicalMetrics); } } + if (metricPool.isEmpty()) { + //nothing to aggregate + continue; + } Map<String, Object> lm = aggregator.aggregate(windowId, metricPool); if (lm != null && lm.size() > 0) {
