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: APEXCORE-363 - NPE in StreamingContainerManager. Skip null in the statistics list in case it was inserted as a result of incorrect CircularBuffer usage in the OperatorContext.
Date Sun, 28 Feb 2016 23:30:11 GMT
Repository: incubator-apex-core
Updated Branches:
  refs/heads/master c2eb06c68 -> c6b3a925a


APEXCORE-363 - NPE in StreamingContainerManager. Skip null in the statistics list in case
it was inserted as a result of incorrect CircularBuffer usage in the OperatorContext.


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/c6b3a925
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/c6b3a925
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/c6b3a925

Branch: refs/heads/master
Commit: c6b3a925a408e767796230ff54055fd2d9f19480
Parents: c2eb06c
Author: Vlad Rozov <v.rozov@datatorrent.com>
Authored: Sun Feb 28 09:55:48 2016 -0800
Committer: Thomas Weise <thomas@datatorrent.com>
Committed: Sun Feb 28 15:29:55 2016 -0800

----------------------------------------------------------------------
 .../java/com/datatorrent/stram/StreamingContainerManager.java    | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/c6b3a925/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 0e7091b..ae79728 100644
--- a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java
+++ b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java
@@ -1570,6 +1570,10 @@ public class StreamingContainerManager implements PlanContext
           entry.getValue().recordingId = null;
         }
         for (ContainerStats.OperatorStats stats : statsList) {
+          if (stats == null) {
+            LOG.warn("Operator {} statistics list contains null element", shb.getNodeId());
+            continue;
+          }
 
           /* report checkpoint-ed WindowId status of the operator */
           if (stats.checkpoint instanceof Checkpoint) {


Mime
View raw message