Github user neeleshs commented on the pull request:
https://github.com/apache/incubator-storm/pull/41#issuecomment-45402968
I have a topology with kafkaspout (parallelism 3, 3 partitions in the
topic). Im using storm 0.9.1 tag and have built it with this patch. That got
rid of the negative timeout error. But every time a message is sent from , one
of the workers dies with this message:
```
2014-06-07 06:43:27 b.s.d.task [INFO] Emitting: processMunchkin
__ack_ack [2264770826798969496 7102317654394246142]
2014-06-07 06:43:27 b.s.util [ERROR] Async loop died!
java.lang.RuntimeException: java.lang.RuntimeException: Client is being
closed, and does not take requests any more
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:107)
~[storm-core-0.9.1.0-incubating.jar:0.9.1.0-incubating]
at
backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:78)
~[storm-core-0.9.1.0-incubating.jar:0.9.1.0-incubating]
at
backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:77)
~[storm-core-0.9.1.0-incubating.jar:0.9.1.0-incubating]
at
backtype.storm.disruptor$consume_loop_STAR_$fn__1577.invoke(disruptor.clj:89)
~[na:na]
at backtype.storm.util$async_loop$fn__384.invoke(util.clj:433)
~[na:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
at java.lang.Thread.run(Thread.java:744) [na:1.7.0_55]
Caused by: java.lang.RuntimeException: Client is being closed, and does
not take requests any more
at backtype.storm.messaging.netty.Client.send(Client.java:125)
~[storm-core-0.9.1.0-incubating.jar:0.9.1.0-incubating]
at
backtype.storm.daemon.worker$mk_transfer_tuples_handler$fn__4398$fn__4399.invoke(worker.clj:319)
~[na:na]
at
backtype.storm.daemon.worker$mk_transfer_tuples_handler$fn__4398.invoke(worker.clj:308)
~[na:na]
at
backtype.storm.disruptor$clojure_handler$reify__1560.onEvent(disruptor.clj:58)
~[na:na]
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:104)
~[storm-core-0.9.1.0-incubating.jar:0.9.1.0-incubating]
... 6 common frames omitted
2014-06-07 06:43:27 b.s.util [INFO] Halting process: ("Async loop
died!")
```
---
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.
---
