Repository: incubator-apex-core Updated Branches: refs/heads/release-3.2 0aaec0c56 -> ce44d2371
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/ce44d237 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/ce44d237 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/ce44d237 Branch: refs/heads/release-3.2 Commit: ce44d2371501a8533d498a5e93de6def2a6cd142 Parents: 0aaec0c Author: ishark <[email protected]> Authored: Wed Oct 21 16:49:00 2015 -0700 Committer: ishark <[email protected]> Committed: Wed Oct 21 17:50:25 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/ce44d237/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; }
