[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007246#comment-15007246 ] ASF GitHub Bot commented on STORM-1208: --- GitHub user d2r opened a pull request: https://github.com/apache/storm/pull/881 [STORM-1208] Guard against NPE, and avoid using NaN values * Removes malformed preconditions that don't do anything, and if they did work would throw Errors that would crash nimbus. * When reading and writing average-type metrics, use `0` instead of `NaN` * Avoid NPE accessing some maps by doing `(get m k)` instead of `(m k)`. You can merge this pull request into a Git repository by running: $ git pull https://github.com/d2r/storm storm-1208-ui-npe-nan Alternatively you can review and apply these changes as the patch at: https://github.com/apache/storm/pull/881.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #881 commit 3857644b4c459cbe42b78ca8a13bd55ef704fd30 Author: Derek Dagit Date: 2015-11-16T20:15:15Z Guard against NPE, and avoid using NaN values > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303)
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007288#comment-15007288 ] ASF GitHub Bot commented on STORM-1208: --- Github user kishorvpatil commented on the pull request: https://github.com/apache/storm/pull/881#issuecomment-157164426 LGTM. +1 > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.daemon.nimbus$fn__5893$exec_fn__1502__auto__$reify__5917.getComponentPageInfo(nimbus.clj:1715) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3677) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3661) > ~[storm-core-0.10.1.jar:0.10.1] > at > org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.security.auth.SaslTransportPlugin$TUGIWrapProcessor.process(SaslTransportPlugin.java:143) > ~[storm-core-0.10.1.ja
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007351#comment-15007351 ] ASF GitHub Bot commented on STORM-1208: --- Github user redsanket commented on the pull request: https://github.com/apache/storm/pull/881#issuecomment-157175212 +1 NB > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.daemon.nimbus$fn__5893$exec_fn__1502__auto__$reify__5917.getComponentPageInfo(nimbus.clj:1715) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3677) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3661) > ~[storm-core-0.10.1.jar:0.10.1] > at > org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.security.auth.SaslTransportPlugin$TUGIWrapProcessor.process(SaslTransportPlugin.java:143) > ~[storm-core-0.10.1.jar:0.10
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007370#comment-15007370 ] ASF GitHub Bot commented on STORM-1208: --- Github user zhuoliu commented on the pull request: https://github.com/apache/storm/pull/881#issuecomment-157178283 Nice fix. +1 > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.daemon.nimbus$fn__5893$exec_fn__1502__auto__$reify__5917.getComponentPageInfo(nimbus.clj:1715) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3677) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3661) > ~[storm-core-0.10.1.jar:0.10.1] > at > org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.security.auth.SaslTransportPlugin$TUGIWrapProcessor.process(SaslTransportPlugin.java:143) > ~[storm-core-0.10.1.jar
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15008049#comment-15008049 ] ASF GitHub Bot commented on STORM-1208: --- Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/881#issuecomment-157268072 it looks good > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.daemon.nimbus$fn__5893$exec_fn__1502__auto__$reify__5917.getComponentPageInfo(nimbus.clj:1715) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3677) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3661) > ~[storm-core-0.10.1.jar:0.10.1] > at > org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.security.auth.SaslTransportPlugin$TUGIWrapProcessor.process(SaslTransportPlugin.java:143) > ~[storm-core-0.10.1.ja
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15008162#comment-15008162 ] ASF GitHub Bot commented on STORM-1208: --- Github user wuchong commented on a diff in the pull request: https://github.com/apache/storm/pull/881#discussion_r45027342 --- Diff: storm-core/src/jvm/backtype/storm/metric/internal/LatencyStatAndMetric.java --- @@ -242,7 +248,7 @@ private synchronized void rotate(long lat, long count, long timeSpent, long targ totalCount += countBuckets[i]; timeNeeded -= bucketTime[i]; } -return ((double)totalLat)/totalCount; +return totalCount > 0 ? ((double)totalLat)/totalCount : 0.0; --- End diff -- Maybe we can pull the code out into a function named like `div-or-0`, as it appears more than once. > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.daemon.nimbus$fn__5893$exec_fn__1502__auto__$reify__5917.getComponentPageInfo(nimbus.clj:1715) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3677) >
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15008882#comment-15008882 ] ASF GitHub Bot commented on STORM-1208: --- Github user d2r commented on a diff in the pull request: https://github.com/apache/storm/pull/881#discussion_r45077073 --- Diff: storm-core/src/jvm/backtype/storm/metric/internal/LatencyStatAndMetric.java --- @@ -242,7 +248,7 @@ private synchronized void rotate(long lat, long count, long timeSpent, long targ totalCount += countBuckets[i]; timeNeeded -= bucketTime[i]; } -return ((double)totalLat)/totalCount; +return totalCount > 0 ? ((double)totalLat)/totalCount : 0.0; --- End diff -- Yes we should do this. In fact, while reading the documentation again, it seems we must guard against both values of `NaN` and `Infinity`. ``` user=> (/ 0. 0.) NaN user=> (/ 1. 0.) Infinity ``` We have only seen the NaN case recently, but it would not hurt to handle both cases, since the dividend and divisor could be 0 independently, especially since the metrics are sampled independently. I will update the code to refactor and to check both. > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) >
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15009053#comment-15009053 ] ASF GitHub Bot commented on STORM-1208: --- Github user d2r commented on the pull request: https://github.com/apache/storm/pull/881#issuecomment-157440029 @hustfxj , @kishorvpatil , @zhuoliu , @redsanket, Added checking for `Infinity` plus some refactoring as per @hustfxj's review. > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.daemon.nimbus$fn__5893$exec_fn__1502__auto__$reify__5917.getComponentPageInfo(nimbus.clj:1715) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3677) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3661) > ~[storm-core-0.10.1.jar:0.10.1] > at > org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.s
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15009806#comment-15009806 ] ASF GitHub Bot commented on STORM-1208: --- Github user kishorvpatil commented on the pull request: https://github.com/apache/storm/pull/881#issuecomment-157540452 still +1. > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.daemon.nimbus$fn__5893$exec_fn__1502__auto__$reify__5917.getComponentPageInfo(nimbus.clj:1715) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3677) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3661) > ~[storm-core-0.10.1.jar:0.10.1] > at > org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.security.auth.SaslTransportPlugin$TUGIWrapProcessor.process(SaslTransportPlugin.java:143) > ~[storm-core-0.10.1.j
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15010028#comment-15010028 ] ASF GitHub Bot commented on STORM-1208: --- Github user wuchong commented on the pull request: https://github.com/apache/storm/pull/881#issuecomment-157572950 +1 LGTM > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.daemon.nimbus$fn__5893$exec_fn__1502__auto__$reify__5917.getComponentPageInfo(nimbus.clj:1715) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3677) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3661) > ~[storm-core-0.10.1.jar:0.10.1] > at > org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.security.auth.SaslTransportPlugin$TUGIWrapProcessor.process(SaslTransportPlugin.java:143) > ~[storm-core-0.10.1.jar:0.10
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15011805#comment-15011805 ] ASF GitHub Bot commented on STORM-1208: --- Github user jerrypeng commented on a diff in the pull request: https://github.com/apache/storm/pull/881#discussion_r45250004 --- Diff: storm-core/src/clj/backtype/storm/stats.clj --- @@ -335,30 +358,21 @@ (defn- agg-bolt-streams-lat-and-count "Aggregates number executed and process & execute latencies." [idk->exec-avg idk->proc-avg idk->executed] - {:pre (apply = (map #(set (keys %)) - [idk->exec-avg - idk->proc-avg - idk->executed]))} - (letfn [(weight-avg [id avg] (let [num-e (idk->executed id)] - (if (and avg num-e) - (* avg num-e) - 0)))] + (letfn [(weight-avg [id avg] +(let [num-e (idk->executed id)] + (product-or-0 avg num-e)))] (into {} (for [k (keys idk->exec-avg)] -[k {:executeLatencyTotal (weight-avg k (idk->exec-avg k)) -:processLatencyTotal (weight-avg k (idk->proc-avg k)) +[k {:executeLatencyTotal (weight-avg k (get idk->exec-avg k)) +:processLatencyTotal (weight-avg k (get idk->proc-avg k)) --- End diff -- what is the point of adding the get especially for (get idk->exec-avg k)? you are getting the keys from the map and then accessing it right? the keys cannot possibly not exist in the map > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] >
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15011814#comment-15011814 ] ASF GitHub Bot commented on STORM-1208: --- Github user asfgit closed the pull request at: https://github.com/apache/storm/pull/881 > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > Fix For: 0.11.0 > > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$fn__2589.doInvoke(stats.clj:1127) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.RestFn.invoke(RestFn.java:436) ~[clojure-1.6.0.jar:?] > at clojure.lang.MultiFn.invoke(MultiFn.java:236) > ~[clojure-1.6.0.jar:?] > at backtype.storm.stats$agg_comp_execs_stats.invoke(stats.clj:1303) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.daemon.nimbus$fn__5893$exec_fn__1502__auto__$reify__5917.getComponentPageInfo(nimbus.clj:1715) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3677) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.generated.Nimbus$Processor$getComponentPageInfo.getResult(Nimbus.java:3661) > ~[storm-core-0.10.1.jar:0.10.1] > at > org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:39) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.security.auth.SaslTransportPlugin$TUGIWrapProcessor.process(SaslTransportPlugin.java:143) > ~[storm-core-0.10.1.jar:0.10.1] >
[jira] [Commented] (STORM-1208) UI: NPE seen when aggregating bolt streams stats
[ https://issues.apache.org/jira/browse/STORM-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15011844#comment-15011844 ] ASF GitHub Bot commented on STORM-1208: --- Github user d2r commented on a diff in the pull request: https://github.com/apache/storm/pull/881#discussion_r45251619 --- Diff: storm-core/src/clj/backtype/storm/stats.clj --- @@ -335,30 +358,21 @@ (defn- agg-bolt-streams-lat-and-count "Aggregates number executed and process & execute latencies." [idk->exec-avg idk->proc-avg idk->executed] - {:pre (apply = (map #(set (keys %)) - [idk->exec-avg - idk->proc-avg - idk->executed]))} - (letfn [(weight-avg [id avg] (let [num-e (idk->executed id)] - (if (and avg num-e) - (* avg num-e) - 0)))] + (letfn [(weight-avg [id avg] +(let [num-e (idk->executed id)] + (product-or-0 avg num-e)))] (into {} (for [k (keys idk->exec-avg)] -[k {:executeLatencyTotal (weight-avg k (idk->exec-avg k)) -:processLatencyTotal (weight-avg k (idk->proc-avg k)) +[k {:executeLatencyTotal (weight-avg k (get idk->exec-avg k)) +:processLatencyTotal (weight-avg k (get idk->proc-avg k)) --- End diff -- ``` user=> (def nilmap nil) #'user/nilmap user=> (get nilmap :somekey) nil user=> (nilmap :somekey) NullPointerException user/eval3 (NO_SOURCE_FILE:4) ``` `get` guards against the map itself is `nil`. > UI: NPE seen when aggregating bolt streams stats > > > Key: STORM-1208 > URL: https://issues.apache.org/jira/browse/STORM-1208 > Project: Apache Storm > Issue Type: Bug > Components: storm-core >Affects Versions: 0.11.0 >Reporter: Derek Dagit >Assignee: Derek Dagit > Fix For: 0.11.0 > > > A stack trace is seen on the UI via its thrift connection to nimbus. > On nimbus, a stack trace similar to the following is seen: > {noformat} > 2015-11-09 19:26:48.921 o.a.t.s.TThreadPoolServer [ERROR] Error occurred > during processing of message. > java.lang.NullPointerException > at > backtype.storm.stats$agg_bolt_streams_lat_and_count$iter__2219__2223$fn__2224.invoke(stats.clj:346) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.6.0.jar:?] > at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.6.0.jar:?] > at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.6.0.jar:?] > at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at clojure.core$into.invoke(core.clj:6341) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$agg_bolt_streams_lat_and_count.invoke(stats.clj:344) > ~[storm-core-0.10.1.jar:0.10.1] > at > backtype.storm.stats$agg_pre_merge_comp_page_bolt.invoke(stats.clj:439) > ~[storm-core-0.10.1.jar:0.10.1] > at backtype.storm.stats$fn__2578.invoke(stats.clj:1093) > ~[storm-core-0.10.1.jar:0.10.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:241) > ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyToHelper(AFn.java:165) ~[clojure-1.6.0.jar:?] > at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?] > at clojure.core$apply.invoke(core.clj:628) ~[clojure-1.6.0.jar:?] > at clojure.core$partial$fn__4230.doInvoke(core.clj:2470) > ~[clojure-1.6.0.jar:?] > at clojure.lang.RestFn.invoke(RestFn.java:421) ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6086.invoke(protocols.clj:143) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6057$G__6052__6066.invoke(protocols.clj:19) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31) > ~[clojure-1.6.0.jar:?] > at clojure.core.protocols$fn__6078.invoke(protocols.clj:54) > ~[clojure-1.6.0.jar:?] > at > clojure.core.protocols$fn__6031$G__6026__6044.invoke(protocols.clj:13) > ~[clojure-1.6.0.jar:?] > at clojure.core$reduce.invoke(core.clj:6289) ~[clojure-1.6.0.jar:?] > at > backtype.storm.stats$aggregate_comp_stats_STAR_.invoke(stats.clj:1106) > ~[storm-core-0.10.1.jar:0.10.1] > at clo