[jira] [Commented] (STORM-3032) NullPointerException in KafkaSpout emitOrRetryTuple
[
https://issues.apache.org/jira/browse/STORM-3032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292739#comment-17292739
]
Benjamin Marwell commented on STORM-3032:
-
This is a known issue:
*
https://ask.clojure.org/index.php/10184/clojure-throws-various-exceptions-immediately-adoptopenjdk
* https://clojure.atlassian.net/browse/CLJ-2609
Reported to IBM. I will report back when/if there is a fix available.
> NullPointerException in KafkaSpout emitOrRetryTuple
> ---
>
> Key: STORM-3032
> URL: https://issues.apache.org/jira/browse/STORM-3032
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-core
>Affects Versions: 1.2.1
> Environment: Linux
>Reporter: Ajeesh B
>Priority: Major
>
> {code:java}
> java.lang.NullPointerException: null
> at clojure.lang.Numbers.ops(Numbers.java:1013) ~[clojure-1.7.0.jar:?]
> at clojure.lang.Numbers.multiply(Numbers.java:148) ~[clojure-1.7.0.jar:?]
> at org.apache.storm.stats$transferred_tuples_BANG_.invoke(stats.clj:131)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$mk_tasks_fn$fn__4656.invoke(task.clj:167)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$send_unanchored.invoke(task.clj:119)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$send_spout_msg__4996.invoke(executor.clj:594)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn$reify__5006.emit(executor.clj:618)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.spout.SpoutOutputCollector.emit(SpoutOutputCollector.java:50)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitOrRetryTuple(KafkaSpout.java:496)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitIfWaitingNotEmitted(KafkaSpout.java:440)
> ~[stormjar.jar:?]
> at org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:308)
> ~[stormjar.jar:?]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$fn__5021.invoke(executor.clj:654)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484)
> [storm-core-1.2.1.jar:1.2.1]
> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
> at java.lang.Thread.run(Thread.java:785) [?:?]
> {code}
> Error in KafkaSpout emitOrRetry method
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (STORM-3032) NullPointerException in KafkaSpout emitOrRetryTuple
[
https://issues.apache.org/jira/browse/STORM-3032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937469#comment-16937469
]
Alexandre Vermeerbergen commented on STORM-3032:
Important detail : we reproduce this issue using Storm 1.2.3 with OpenJ9 flavor
of AdoptOpenJDK 8 update 222 to run Supervisor (supervisor, worker, log
analyzer) processes.
We do not reproduce this issue using Storm 1.2.3 with HotSpot flavor of
AdoptOpenJDK8 update 222 run Supervisor processes.
Hope it helps,
Alexandre Vermeerbergen
> NullPointerException in KafkaSpout emitOrRetryTuple
> ---
>
> Key: STORM-3032
> URL: https://issues.apache.org/jira/browse/STORM-3032
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-core
>Affects Versions: 1.2.1
> Environment: Linux
>Reporter: Ajeesh B
>Priority: Major
>
> {code:java}
> java.lang.NullPointerException: null
> at clojure.lang.Numbers.ops(Numbers.java:1013) ~[clojure-1.7.0.jar:?]
> at clojure.lang.Numbers.multiply(Numbers.java:148) ~[clojure-1.7.0.jar:?]
> at org.apache.storm.stats$transferred_tuples_BANG_.invoke(stats.clj:131)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$mk_tasks_fn$fn__4656.invoke(task.clj:167)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$send_unanchored.invoke(task.clj:119)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$send_spout_msg__4996.invoke(executor.clj:594)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn$reify__5006.emit(executor.clj:618)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.spout.SpoutOutputCollector.emit(SpoutOutputCollector.java:50)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitOrRetryTuple(KafkaSpout.java:496)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitIfWaitingNotEmitted(KafkaSpout.java:440)
> ~[stormjar.jar:?]
> at org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:308)
> ~[stormjar.jar:?]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$fn__5021.invoke(executor.clj:654)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484)
> [storm-core-1.2.1.jar:1.2.1]
> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
> at java.lang.Thread.run(Thread.java:785) [?:?]
> {code}
> Error in KafkaSpout emitOrRetry method
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (STORM-3032) NullPointerException in KafkaSpout emitOrRetryTuple
[
https://issues.apache.org/jira/browse/STORM-3032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935404#comment-16935404
]
Stig Rohde Døssing commented on STORM-3032:
---
This does not seem to be an issue as of 2.x. Could you try upgrading to that?
> NullPointerException in KafkaSpout emitOrRetryTuple
> ---
>
> Key: STORM-3032
> URL: https://issues.apache.org/jira/browse/STORM-3032
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-core
>Affects Versions: 1.2.1
> Environment: Linux
>Reporter: Ajeesh B
>Priority: Major
>
> {code:java}
> java.lang.NullPointerException: null
> at clojure.lang.Numbers.ops(Numbers.java:1013) ~[clojure-1.7.0.jar:?]
> at clojure.lang.Numbers.multiply(Numbers.java:148) ~[clojure-1.7.0.jar:?]
> at org.apache.storm.stats$transferred_tuples_BANG_.invoke(stats.clj:131)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$mk_tasks_fn$fn__4656.invoke(task.clj:167)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$send_unanchored.invoke(task.clj:119)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$send_spout_msg__4996.invoke(executor.clj:594)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn$reify__5006.emit(executor.clj:618)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.spout.SpoutOutputCollector.emit(SpoutOutputCollector.java:50)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitOrRetryTuple(KafkaSpout.java:496)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitIfWaitingNotEmitted(KafkaSpout.java:440)
> ~[stormjar.jar:?]
> at org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:308)
> ~[stormjar.jar:?]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$fn__5021.invoke(executor.clj:654)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484)
> [storm-core-1.2.1.jar:1.2.1]
> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
> at java.lang.Thread.run(Thread.java:785) [?:?]
> {code}
> Error in KafkaSpout emitOrRetry method
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (STORM-3032) NullPointerException in KafkaSpout emitOrRetryTuple
[
https://issues.apache.org/jira/browse/STORM-3032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933099#comment-16933099
]
Suyog Dhokpande commented on STORM-3032:
Hello,
We are also getting the exception in KafkaSpout's emitOrRetry method with Storm
1.2.3 and Kafka client at version 2.0.1.
Any suggestion or guidance ?
> NullPointerException in KafkaSpout emitOrRetryTuple
> ---
>
> Key: STORM-3032
> URL: https://issues.apache.org/jira/browse/STORM-3032
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-core
>Affects Versions: 1.2.1
> Environment: Linux
>Reporter: Ajeesh B
>Priority: Major
>
> {code:java}
> java.lang.NullPointerException: null
> at clojure.lang.Numbers.ops(Numbers.java:1013) ~[clojure-1.7.0.jar:?]
> at clojure.lang.Numbers.multiply(Numbers.java:148) ~[clojure-1.7.0.jar:?]
> at org.apache.storm.stats$transferred_tuples_BANG_.invoke(stats.clj:131)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$mk_tasks_fn$fn__4656.invoke(task.clj:167)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$send_unanchored.invoke(task.clj:119)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$send_spout_msg__4996.invoke(executor.clj:594)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn$reify__5006.emit(executor.clj:618)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.spout.SpoutOutputCollector.emit(SpoutOutputCollector.java:50)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitOrRetryTuple(KafkaSpout.java:496)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitIfWaitingNotEmitted(KafkaSpout.java:440)
> ~[stormjar.jar:?]
> at org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:308)
> ~[stormjar.jar:?]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$fn__5021.invoke(executor.clj:654)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484)
> [storm-core-1.2.1.jar:1.2.1]
> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
> at java.lang.Thread.run(Thread.java:785) [?:?]
> {code}
> Error in KafkaSpout emitOrRetry method
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (STORM-3032) NullPointerException in KafkaSpout emitOrRetryTuple
[
https://issues.apache.org/jira/browse/STORM-3032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932498#comment-16932498
]
Alexandre Vermeerbergen commented on STORM-3032:
Hello,
We are getting the same exception with Storm 1.2.3, using Kafka client at
version 2.0.1, against Kafka Brokers at version 2.1.1.
Since this is a NullPointerException that seems to be related to some
statistics computation, isn't there a way to catch it so as to limit noise in
Storm logs, unless that hint about a severe issue and thus some guidance to
understand the issue & recommendations to solve it would be welcomed ?
Kind regards,
Alexandre Vermeerbergen
> NullPointerException in KafkaSpout emitOrRetryTuple
> ---
>
> Key: STORM-3032
> URL: https://issues.apache.org/jira/browse/STORM-3032
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-core
>Affects Versions: 1.2.1
> Environment: Linux
>Reporter: Ajeesh B
>Priority: Major
>
> {code:java}
> java.lang.NullPointerException: null
> at clojure.lang.Numbers.ops(Numbers.java:1013) ~[clojure-1.7.0.jar:?]
> at clojure.lang.Numbers.multiply(Numbers.java:148) ~[clojure-1.7.0.jar:?]
> at org.apache.storm.stats$transferred_tuples_BANG_.invoke(stats.clj:131)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$mk_tasks_fn$fn__4656.invoke(task.clj:167)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.daemon.task$send_unanchored.invoke(task.clj:119)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$send_spout_msg__4996.invoke(executor.clj:594)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.daemon.executor$fn__4975$fn$reify__5006.emit(executor.clj:618)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.spout.SpoutOutputCollector.emit(SpoutOutputCollector.java:50)
> ~[storm-core-1.2.1.jar:1.2.1]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitOrRetryTuple(KafkaSpout.java:496)
> ~[stormjar.jar:?]
> at
> org.apache.storm.kafka.spout.KafkaSpout.emitIfWaitingNotEmitted(KafkaSpout.java:440)
> ~[stormjar.jar:?]
> at org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:308)
> ~[stormjar.jar:?]
> at
> org.apache.storm.daemon.executor$fn__4975$fn__4990$fn__5021.invoke(executor.clj:654)
> ~[storm-core-1.2.1.jar:1.2.1]
> at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484)
> [storm-core-1.2.1.jar:1.2.1]
> at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
> at java.lang.Thread.run(Thread.java:785) [?:?]
> {code}
> Error in KafkaSpout emitOrRetry method
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
