APEX-212 #resolve Adding a check for physical operators list being empty in fillOperatorInfo
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/83f95d82 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/83f95d82 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/83f95d82 Branch: refs/heads/feature-module Commit: 83f95d82db4549ea48be4965257605c147998187 Parents: e3cecc2 Author: ishark <[email protected]> Authored: Wed Oct 21 16:49:00 2015 -0700 Committer: Thomas Weise <[email protected]> Committed: Wed Oct 21 18:19:35 2015 -0700 ---------------------------------------------------------------------- .../com/datatorrent/stram/StreamingContainerManager.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/83f95d82/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 3931fad..ca724db 100644 --- a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java +++ b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java @@ -2396,9 +2396,12 @@ public class StreamingContainerManager implements PlanContext } } } - loi.checkpointTimeMA = checkpointTimeAggregate.getAvg().longValue(); - loi.counters = latestLogicalCounters.get(operator.getName()); - loi.autoMetrics = latestLogicalMetrics.get(operator.getName()); + if (physicalOperators.size() > 0) { + loi.checkpointTimeMA = checkpointTimeAggregate.getAvg().longValue(); + loi.counters = latestLogicalCounters.get(operator.getName()); + loi.autoMetrics = latestLogicalMetrics.get(operator.getName()); + } + return loi; }
