[STORM-1937] trident topologies WindowTridentProcessor cause NullPointerException when using windowing

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0, 1.0.1
• Fix Version/s: 2.0.0, 1.0.2, 1.1.0
• Component/s: storm-core
• Flags: Patch
• Epic Link: Release Apache Storm 1.0.2
• Assignee: perry wang
• Reporter: perry wang
• Created: 30/Jun/16 09:46
• Updated: 03/Jul/16 06:49
• Resolved: 03/Jul/16 06:49

Description

I'm working with trident and try to use windows support, under the local model is fine, but in distributed mode we got the following excepiton(I can reliably reproduce this issue):

java.lang.RuntimeException: java.lang.NullPointerException
at org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:452) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:418) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.daemon.executor$fn_7953$fn7966$fn_8019.invoke(executor.clj:847) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.util$async_loop$fn__625.invoke(util.clj:484) [storm-core-1.0.1.jar:1.0.1]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:744) [?:1.7.0_51]
Caused by: java.lang.NullPointerException
at org.apache.storm.trident.windowing.WindowTridentProcessor.finishBatch(WindowTridentProcessor.java:167) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.trident.planner.SubtopologyBolt.finishBatch(SubtopologyBolt.java:151) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.trident.topology.TridentBoltExecutor.finishBatch(TridentBoltExecutor.java:266) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.trident.topology.TridentBoltExecutor.checkFinish(TridentBoltExecutor.java:299) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.trident.topology.TridentBoltExecutor.execute(TridentBoltExecutor.java:378) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.daemon.executor$fn_7953$tuple_action_fn_7955.invoke(executor.clj:728) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.daemon.executor$mk_task_receiver$fn__7874.invoke(executor.clj:461) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.disruptor$clojure_handler$reify__7390.onEvent(disruptor.clj:40) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:439) ~[storm-core-1.0.1.jar:1.0.1]
... 6 more

Issue Links

• links to: GitHub Pull Request #1531