Repository: incubator-apex-core Updated Branches: refs/heads/release-3.3 da2f0edb2 -> d272bfaa9
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/d272bfaa Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/d272bfaa Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/d272bfaa Branch: refs/heads/release-3.3 Commit: d272bfaa916e221af806931089f8c93242153b71 Parents: da2f0ed Author: Vlad Rozov <[email protected]> Authored: Sun Feb 28 09:55:48 2016 -0800 Committer: Thomas Weise <[email protected]> Committed: Sun Feb 28 15:28:21 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/d272bfaa/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) {
