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

Supervisor V2 can possibly shut down workers twice in local mode

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.0.0, 1.1.0
    • Fix Version/s: 2.0.0, 1.1.0, 1.0.3
    • Component/s: storm-core
    • Labels:
      None

      Description

      See https://github.com/apache/storm/pull/1697#issuecomment-256456889

      java.lang.NullPointerException
          at org.apache.storm.utils.DisruptorQueue$FlusherPool.stop(DisruptorQueue.java:110)
          at org.apache.storm.utils.DisruptorQueue$Flusher.close(DisruptorQueue.java:293)
          at org.apache.storm.utils.DisruptorQueue.haltWithInterrupt(DisruptorQueue.java:410)
          at org.apache.storm.disruptor$halt_with_interrupt_BANG_.invoke(disruptor.clj:77)
          at org.apache.storm.daemon.executor$mk_executor$reify__4923.shutdown(executor.clj:412)
          at sun.reflect.GeneratedMethodAccessor303.invoke(Unknown Source)
          at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
          at java.lang.reflect.Method.invoke(Method.java:498)
          at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
          at clojure.lang.Reflector.invokeNoArgInstanceMember(Reflector.java:313)
          at org.apache.storm.daemon.worker$fn__5550$exec_fn__1372__auto__$reify__5552$shutdown_STAR___5572.invoke(worker.clj:668)
          at org.apache.storm.daemon.worker$fn__5550$exec_fn__1372__auto__$reify$reify__5598.shutdown(worker.clj:706)
          at org.apache.storm.ProcessSimulator.killProcess(ProcessSimulator.java:66)
          at org.apache.storm.ProcessSimulator.killAllProcesses(ProcessSimulator.java:79)
          at org.apache.storm.testing$kill_local_storm_cluster.invoke(testing.clj:207)
          at org.apache.storm.testing4j$_withLocalCluster.invoke(testing4j.clj:93)
          at org.apache.storm.Testing.withLocalCluster(Unknown Source)
      

      and

      java.lang.IllegalStateException: Timer is not active
          at org.apache.storm.timer$check_active_BANG_.invoke(timer.clj:87)
          at org.apache.storm.timer$cancel_timer.invoke(timer.clj:120)
          at org.apache.storm.daemon.worker$fn__5550$exec_fn__1372__auto__$reify__5552$shutdown_STAR___5572.invoke(worker.clj:682)
          at org.apache.storm.daemon.worker$fn__5550$exec_fn__1372__auto__$reify$reify__5598.shutdown(worker.clj:706)
          at org.apache.storm.ProcessSimulator.killProcess(ProcessSimulator.java:66)
          at org.apache.storm.ProcessSimulator.killAllProcesses(ProcessSimulator.java:79)
          at org.apache.storm.testing$kill_local_storm_cluster.invoke(testing.clj:207)
          at org.apache.storm.testing4j$_withLocalCluster.invoke(testing4j.clj:93)
          at org.apache.storm.Testing.withLocalCluster(Unknown Source)
      

      Stig Rohde Døssing is still working on getting a reproducible use case for us. But I will try to reproduce/fix it myself in the mean time.

        Attachments

          Activity

            People

            • Assignee:
              revans2 Robert Joseph Evans
              Reporter:
              revans2 Robert Joseph Evans
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 1h 50m
                1h 50m