Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-3033

NullPointerException in consumeBatchToCursor method

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.2.1
    • Fix Version/s: None
    • Component/s: storm-core
    • Labels:
      None
    • Environment:
      Linux

      Description

      Error in consumeBatchToCursor method after few days or running. Error occurred on bolt's ack method call.

      Linked Issue: https://issues.apache.org/jira/browse/STORM-770

       

      java.lang.RuntimeException: java.lang.NullPointerException
      at org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:522) ~[storm-core-1.2.1.jar:1.2.1]
      at org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:487) ~[storm-core-1.2.1.jar:1.2.1]
      at org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:74) ~[storm-core-1.2.1.jar:1.2.1]
      at org.apache.storm.daemon.executor$fn__5043$fn__5056$fn__5109.invoke(executor.clj:861) ~[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) [?:?]
      Caused by: java.lang.NullPointerException
      at org.apache.storm.stats$emitted_tuple_BANG_.invoke(stats.clj:123) ~[storm-core-1.2.1.jar:1.2.1]
      at org.apache.storm.daemon.task$mk_tasks_fn$fn__4656.invoke(task.clj:166) ~[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__5043$fn$reify__5068.ack(executor.clj:816) ~[storm-core-1.2.1.jar:1.2.1]
      at org.apache.storm.task.OutputCollector.ack(OutputCollector.java:213) ~[storm-core-1.2.1.jar:1.2.1]
      at bolt execute method
      at org.apache.storm.daemon.executor$fn__5043$tuple_action_fn__5045.invoke(executor.clj:739) ~[storm-core-1.2.1.jar:1.2.1]
      at org.apache.storm.daemon.executor$mk_task_receiver$fn__4964.invoke(executor.clj:468) ~[storm-core-1.2.1.jar:1.2.1]
      at org.apache.storm.disruptor$clojure_handler$reify__4475.onEvent(disruptor.clj:41) ~[storm-core-1.2.1.jar:1.2.1]
      at org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:509) ~[storm-core-1.2.1.jar:1.2.1]
      ... 6 more
      

       

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              Ajeesh Ajeesh B
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: