Github user iwasakims commented on the pull request:
https://github.com/apache/incubator-storm/pull/193#issuecomment-49348655
@d2r, launch-worker and shutdown-worker are called from sync-processes
which called every 3 seconds by even-manager thread in supervisor.
If you submit-local-topology inside capture-changed-workers,
advance-cluster-time also should be called inside the capture-changed-worker
because launch-worker and shutdown-worker are mocked only inside it. If you
advance-cluster-time outside capture-changed-worker, actual launch-worker
(:local) is called and the test process halt because of interrupt at end of the
test.
```
25524 [Thread-14] ERROR backtype.storm.daemon.worker - Error on
initialization of server mk-worker
java.io.InterruptedIOException: null
at reply.hacks.printing$print_sequential.invoke(printing.clj:31)
~[na:na]
at clojure.core$print_map.invoke(core_print.clj:203)
~[clojure-1.5.1.jar:na]
at clojure.core$fn__5431.invoke(core_print.clj:207)
~[clojure-1.5.1.jar:na]
at clojure.lang.MultiFn.invoke(MultiFn.java:231) [clojure-1.5.1.jar:na]
at clojure.core$pr_on.invoke(core.clj:3322) ~[clojure-1.5.1.jar:na]
at clojure.lang.Var.invoke(Var.java:419) ~[clojure-1.5.1.jar:na]
at clojure.lang.RT.print(RT.java:1748) [clojure-1.5.1.jar:na]
at clojure.lang.RT.printString(RT.java:1727) [clojure-1.5.1.jar:na]
at clojure.lang.APersistentMap.toString(APersistentMap.java:21)
~[clojure-1.5.1.jar:na]
at clojure.core$str.invoke(core.clj:513) ~[clojure-1.5.1.jar:na]
at clojure.core$str$fn__3896.invoke(core.clj:517)
~[clojure-1.5.1.jar:na]
at clojure.core$str.doInvoke(core.clj:519) ~[clojure-1.5.1.jar:na]
at clojure.lang.RestFn.invoke(RestFn.java:816) [clojure-1.5.1.jar:na]
at
backtype.storm.daemon.worker$fn__6855$exec_fn__2478__auto____6856.invoke(worker.clj:356)
~[classes/:na]
at clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.5.1.jar:na]
at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
at clojure.core$apply.invoke(core.clj:617) [clojure-1.5.1.jar:na]
at
backtype.storm.daemon.worker$fn__6855$mk_worker__6911.doInvoke(worker.clj:355)
[classes/:na]
at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.5.1.jar:na]
at backtype.storm.daemon.supervisor$fn__7382.invoke(supervisor.clj:561)
[classes/:na]
at clojure.lang.MultiFn.invoke(MultiFn.java:241) [clojure-1.5.1.jar:na]
at
backtype.storm.daemon.supervisor$sync_processes$iter__7226__7230$fn__7231.invoke(supervisor.clj:277)
[classes/:na]
at clojure.lang.LazySeq.sval(LazySeq.java:42) [clojure-1.5.1.jar:na]
at clojure.lang.LazySeq.seq(LazySeq.java:60) [clojure-1.5.1.jar:na]
at clojure.lang.RT.seq(RT.java:484) [clojure-1.5.1.jar:na]
at clojure.core$seq.invoke(core.clj:133) [clojure-1.5.1.jar:na]
at clojure.core$dorun.invoke(core.clj:2780) [clojure-1.5.1.jar:na]
at clojure.core$doall.invoke(core.clj:2796) [clojure-1.5.1.jar:na]
at
backtype.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:265)
[classes/:na]
at clojure.lang.AFn.applyToHelper(AFn.java:161) [clojure-1.5.1.jar:na]
at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
at clojure.core$apply.invoke(core.clj:619) [clojure-1.5.1.jar:na]
at clojure.core$partial$fn__4190.doInvoke(core.clj:2396)
[clojure-1.5.1.jar:na]
at clojure.lang.RestFn.invoke(RestFn.java:397) [clojure-1.5.1.jar:na]
at backtype.storm.event$event_manager$fn__4814.invoke(event.clj:39)
[classes/:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:744) [na:1.7.0_45]
25525 [Thread-14] INFO backtype.storm.util - Halting process: ("Error on
initialization")
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
