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/10/22 03:21:13 UTC
incubator-apex-core git commit: APEX-212 #resolve Adding a check for
physical operators list being empty in fillOperatorInfo
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 <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;
}