Repository: storm Updated Branches: refs/heads/1.x-branch 148ee6609 -> 9aff9f91b
STORM-2779 NPE on shutting down WindowedBoltExecutor * waterMarkEventGenerator could be null when timestamp field is not specified Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/40384cf5 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/40384cf5 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/40384cf5 Branch: refs/heads/1.x-branch Commit: 40384cf5f21337cc496660c1bf0c59ad41d30788 Parents: 39e12aa Author: Jungtaek Lim <[email protected]> Authored: Tue Oct 17 12:40:48 2017 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Tue Oct 17 12:42:11 2017 +0900 ---------------------------------------------------------------------- .../src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/40384cf5/storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java b/storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java index 26c69a2..c9afc67 100644 --- a/storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java +++ b/storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java @@ -299,7 +299,9 @@ public class WindowedBoltExecutor implements IRichBolt { @Override public void cleanup() { - waterMarkEventGenerator.shutdown(); + if (waterMarkEventGenerator != null) { + waterMarkEventGenerator.shutdown(); + } windowManager.shutdown(); bolt.cleanup(); }
