Hi All,
We want to migrate our project from Storm v0.8.1 to v9.0.1, but our
integration tests do not run under Storm v0.9.0.1. The problem appears when
the topology under test is killed or the local cluster shutdown : the JVM
process doesn't exit.
This problem appears some times in v0.8.0.1, but always in v0.9.1.
The thread dump shows always the same thread blocked :
"Thread-9" prio=10 tid=0x00007f9244ca1000 nid=0x5599 waiting for monitor
entry [0x00007f9233bfa000]
java.lang.Thread.State: BLOCKED (on object monitor)
at
backtype.storm.process_simulator$kill_process.invoke(process_simulator.clj:20)
- waiting to lock <0x0000000749e01060> (a java.lang.Object)
at
backtype.storm.daemon.supervisor$shutdown_worker.invoke(supervisor.clj:155)
at
backtype.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:220)
at clojure.lang.AFn.applyToHelper(AFn.java:161)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:603)
at clojure.core$partial$fn__4070.doInvoke(core.clj:2343)
at clojure.lang.RestFn.invoke(RestFn.java:397)
at backtype.storm.event$event_manager$fn__3072.invoke(event.clj:24)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:744)
It is a bug from Storm, or have you an idea how to fix the problem ?
Thank you,
Benoît
