apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject incubator-apex-core git commit: APEX-212 #resolve Adding a check for physical operators list being empty in fillOperatorInfo
Date Thu, 22 Oct 2015 01:21:13 GMT
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 <isha@datatorrent.com>
Authored: Wed Oct 21 16:49:00 2015 -0700
Committer: ishark <isha@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;
   }
 


Mime
View raw message