[jira] [Updated] (METRON-1751) Storm Profiler dies when consuming null message
[ https://issues.apache.org/jira/browse/METRON-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nick Allen updated METRON-1751: --- Fix Version/s: 0.6.0 > Storm Profiler dies when consuming null message > --- > > Key: METRON-1751 > URL: https://issues.apache.org/jira/browse/METRON-1751 > Project: Metron > Issue Type: Bug >Reporter: Mohan >Assignee: Nick Allen >Priority: Major > Fix For: 0.6.0 > > > When You publish a null message to the profiler input kafka topic which is > 'indexing' in my case I see the below exception messages on the worker log > {code:java} > 2018-08-27 12:46:03.825 o.a.s.util Thread-9-splitterBolt-executor[7 7] > [ERROR] Async loop died! java.lang.RuntimeException: > java.lang.NullPointerException at > org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:485) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:451) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.daemon.executor$fn__10195$fn__10208$fn__10263.invoke(executor.clj:855) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.util$async_loop$fn__1221.invoke(util.clj:484) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] at > java.lang.Thread.run(Thread.java:748) [?:1.8.0_181] Caused by: > java.lang.NullPointerException at java.lang.String.(String.java:491) > ~[?:1.8.0_181] at > org.apache.metron.profiler.bolt.ProfileSplitterBolt.doExecute(ProfileSplitterBolt.java:160) > ~[stormjar.jar:?] at > org.apache.metron.profiler.bolt.ProfileSplitterBolt.execute(ProfileSplitterBolt.java:145) > ~[stormjar.jar:?] at > org.apache.storm.daemon.executor$fn__10195$tuple_action_fn__10197.invoke(executor.clj:735) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.daemon.executor$mk_task_receiver$fn__10114.invoke(executor.clj:466) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.disruptor$clojure_handler$reify__4137.onEvent(disruptor.clj:40) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:472) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] ... 6 more > {code} > also the profiler dies , even if you start up the profiler again and run it > through the same topic, it does always die. > {code:java} > 2018-08-27 12:46:03.870 o.a.s.util Thread-9-splitterBolt-executor[7 7] > [ERROR] Halting process: ("Worker died") > java.lang.RuntimeException: ("Worker died") > at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] > at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?] > at > org.apache.storm.daemon.worker$fn__10799$fn__10800.invoke(worker.clj:763) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] > at > org.apache.storm.daemon.executor$mk_executor_data$fn__10011$fn__10012.invoke(executor.clj:276) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] > at org.apache.storm.util$async_loop$fn__1221.invoke(util.clj:494) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] > at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] > at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181] > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (METRON-1751) Storm Profiler dies when consuming null message
[ https://issues.apache.org/jira/browse/METRON-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nick Allen updated METRON-1751: --- Summary: Storm Profiler dies when consuming null message (was: Profiler dies if we push a null message to the configured profiler input topic ) > Storm Profiler dies when consuming null message > --- > > Key: METRON-1751 > URL: https://issues.apache.org/jira/browse/METRON-1751 > Project: Metron > Issue Type: Bug >Reporter: Mohan >Priority: Major > > When You publish a null message to the profiler input kafka topic which is > 'indexing' in my case I see the below exception messages on the worker log > {code:java} > 2018-08-27 12:46:03.825 o.a.s.util Thread-9-splitterBolt-executor[7 7] > [ERROR] Async loop died! java.lang.RuntimeException: > java.lang.NullPointerException at > org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:485) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:451) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.daemon.executor$fn__10195$fn__10208$fn__10263.invoke(executor.clj:855) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.util$async_loop$fn__1221.invoke(util.clj:484) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] at > java.lang.Thread.run(Thread.java:748) [?:1.8.0_181] Caused by: > java.lang.NullPointerException at java.lang.String.(String.java:491) > ~[?:1.8.0_181] at > org.apache.metron.profiler.bolt.ProfileSplitterBolt.doExecute(ProfileSplitterBolt.java:160) > ~[stormjar.jar:?] at > org.apache.metron.profiler.bolt.ProfileSplitterBolt.execute(ProfileSplitterBolt.java:145) > ~[stormjar.jar:?] at > org.apache.storm.daemon.executor$fn__10195$tuple_action_fn__10197.invoke(executor.clj:735) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.daemon.executor$mk_task_receiver$fn__10114.invoke(executor.clj:466) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.disruptor$clojure_handler$reify__4137.onEvent(disruptor.clj:40) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] at > org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:472) > ~[storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] ... 6 more > {code} > also the profiler dies , even if you start up the profiler again and run it > through the same topic, it does always die. > {code:java} > 2018-08-27 12:46:03.870 o.a.s.util Thread-9-splitterBolt-executor[7 7] > [ERROR] Halting process: ("Worker died") > java.lang.RuntimeException: ("Worker died") > at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] > at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?] > at > org.apache.storm.daemon.worker$fn__10799$fn__10800.invoke(worker.clj:763) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] > at > org.apache.storm.daemon.executor$mk_executor_data$fn__10011$fn__10012.invoke(executor.clj:276) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] > at org.apache.storm.util$async_loop$fn__1221.invoke(util.clj:494) > [storm-core-1.1.0.2.6.5.0-292.jar:1.1.0.2.6.5.0-292] > at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] > at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181] > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)