You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2015/11/03 03:27:40 UTC
[39/50] [abbrv] 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/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/master
Commit: ce44d2371501a8533d498a5e93de6def2a6cd142
Parents: 0aaec0c
Author: ishark <is...@datatorrent.com>
Authored: Wed Oct 21 16:49:00 2015 -0700
Committer: ishark <is...@datatorrent.com>
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;
}