You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2015/10/25 20:38:11 UTC
[28/36] incubator-apex-core git commit: APEX-212 #resolve Adding a
check for physical operators list being empty in fillOperatorInfo
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 <is...@datatorrent.com>
Authored: Wed Oct 21 16:49:00 2015 -0700
Committer: Thomas Weise <th...@datatorrent.com>
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;
}