[
https://issues.apache.org/jira/browse/STORM-187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13861477#comment-13861477
]
Jose Ignacio Honrado commented on STORM-187:
--------------------------------------------
More log traces:
2014-01-03 12:38:08 b.s.m.n.Client [WARN] Remote address is not reachable. We
will close this client.
2014-01-03 12:38:09 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:90)
~[storm-core-0.9.0.1.jar:na]
at
backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:61)
~[storm-core-0.9.0.1.jar:na]
at
backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:62)
~[storm-core-0.9.0.1.jar:na]
at
backtype.storm.disruptor$consume_loop_STAR_$fn__2975.invoke(disruptor.clj:74)
~[storm-core-0.9.0.1.jar:na]
at backtype.storm.util$async_loop$fn__444.invoke(util.clj:403)
~[storm-core-0.9.0.1.jar: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_45]
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:109)
~[storm-netty-0.9.0.1.jar:na]
at
backtype.storm.daemon.worker$mk_transfer_tuples_handler$fn__5867$fn__5868.invoke(worker.clj:304)
~[storm-core-0.9.0.1.jar:na]
at
backtype.storm.daemon.worker$mk_transfer_tuples_handler$fn__5867.invoke(worker.clj:293)
~[storm-core-0.9.0.1.jar:na]
at
backtype.storm.disruptor$clojure_handler$reify__2962.onEvent(disruptor.clj:43)
~[storm-core-0.9.0.1.jar:na]
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:87)
~[storm-core-0.9.0.1.jar:na]
... 6 common frames omitted
I tried to map the hostnames of the different components of the storm
architecture (nimbus, zookepers and workers) to their IPs in /etc/hosts just in
case, but the result is the same.
> From ZMQ to Netty "java.lang.IllegalArgumentException: timeout value is
> negative"
> ---------------------------------------------------------------------------------
>
> Key: STORM-187
> URL: https://issues.apache.org/jira/browse/STORM-187
> Project: Apache Storm (Incubating)
> Issue Type: Bug
> Reporter: Jose Ignacio Honrado
> Priority: Critical
> Labels: netty, storm, zeromq
>
> Hi,
> I am trying to use Netty as the transport layer in storm 0.9.0.1 but I am
> getting the following error trace:
> {code}
> java.lang.IllegalArgumentException: timeout value is negative
> at java.lang.Thread.sleep(Native Method)
> at backtype.storm.messaging.netty.Client.reconnect(Client.java:78)
> at
> backtype.storm.messaging.netty.StormClientHandler.exceptionCaught(StormClientHandler.java:108)
> at
> org.jboss.netty.handler.codec.frame.FrameDecoder.exceptionCaught(FrameDecoder.java:377)
> at org.jboss.netty.channel.Channels.fireExceptionCaught(Channels.java:525)
> at
> org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:109)
> at
> org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:78)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
> at
> org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:41)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:744)
> {/code}
> I am using the following supervisor config:
> {code}
> storm.zookeeper.servers:
> - "son-rtl-dev-zook1"
> storm.zookeeper.port: 9000
> storm.local.dir: "/mnt/storm"
> storm.local.hostname: "son-rtl-dev-superv1"
> java.library.path: "/usr/local/lib"
> nimbus.host: "son-rtl-dev-nimbus"
> nimbus.task.launch.secs: 240
> supervisor.worker.start.timeout.secs: 240
> supervisor.worker.timeout.secs: 240
> supervisor.childopts: "-Xmx512m -Djava.net.preferIPv4Stack=true"
> supervisor.slots.ports:
> - 6700
> - 6701
> - 6702
> - 6703
> - 6704
> - 6705
> - 6706
> - 6707
> worker.childopts: "-Xmx512m -Djava.net.preferIPv4Stack=true"
> nimbus.childopts: "-Xmx512m -Djava.net.preferIPv4Stack=true"
> topology.message.timeout.secs: 1
> storm.messaging.transport: "backtype.storm.messaging.netty.Context"
> storm.messaging.netty.server_worker_threads: 1
> storm.messaging.netty.client_worker_threads: 1
> storm.messaging.netty.buffer_size: 5242880
> storm.messaging.netty.max_retries: 30
> storm.messaging.netty.max_wait_ms: 1000
> storm.messaging.netty.min_wait_ms: 100
> {/code}
> Without these last config lines, topologies are working fine using ZMQ.
> Any idea?
> Thanks
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
