apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vro...@apache.org
Subject [28/36] incubator-apex-core git commit: APEX-212 #resolve Adding a check for physical operators list being empty in fillOperatorInfo
Date Sun, 25 Oct 2015 19:38:11 GMT
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 <isha@datatorrent.com>
Authored: Wed Oct 21 16:49:00 2015 -0700
Committer: Thomas Weise <thomas@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;
   }
 


Mime
View raw message