You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by P Ghosh <ja...@gmail.com> on 2014/06/03 22:08:07 UTC
java.lang.IllegalArgumentException: timeout value is negative
I'm getting this exception
2014-06-03 19:59:13 STDIO [ERROR][id:] Jun 03, 2014 7:59:13 PM
org.jboss.netty.channel.DefaultChannelPipeline
WARNING: An exception was thrown by a user handler while handling an
exception event ([id: 0xdcf3be42] EXCEPTION: java.net.ConnectException:
Connection refused)
java.lang.IllegalArgumentException: timeout value is negative
at java.lang.Thread.sleep(Native Method)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:94)
at
backtype.storm.messaging.netty.StormClientHandler.exceptionCaught(StormClientHandler.java:118)
at
org.jboss.netty.handler.codec.frame.FrameDecoder.exceptionCaught(FrameDecoder.java:377)
*Here's my storm.yaml (from nimbus/zookeeper only server.... hence ports
are commented)*
storm.zookeeper.servers:
- "ma-app05.corp.mydomain.com"
storm.zookeeper.port: 2181
storm.zookeeper.root: "/storm"
storm.zookeeper.session.timeout: 20000
storm.zookeeper.connection.timeout: 15000
storm.zookeeper.retry.times: 5
storm.zookeeper.retry.interval: 1000
storm.zookeeper.retry.intervalceiling.millis: 30000
nimbus.host: "ma-app05.corp.mydomain.com"
nimbus.thrift.port: 6627
nimbus.thrift.max_buffer_size: 1048576
nimbus.childopts: "-Xmx1024m"
nimbus.task.timeout.secs: 30
nimbus.supervisor.timeout.secs: 60
nimbus.monitor.freq.secs: 10
nimbus.cleanup.inbox.freq.secs: 600
nimbus.inbox.jar.expiration.secs: 3600
nimbus.task.launch.secs: 120
nimbus.reassign: true
nimbus.file.copy.expiration.secs: 600
nimbus.topology.validator: "backtype.storm.nimbus.DefaultTopologyValidator"
#No supervisor in Nimbus. Pls. note that storm might still be loading the
default conf, if it requires.
#supervisor.slots.ports:
# - 9951
# - 9952
# - 9953
# - 9954
# - 9955
#supervisor.worker.start.timeout.secs: 120
#supervisor.worker.timeout.secs: 30
#supervisor.monitor.frequency.secs: 3
#supervisor.heartbeat.frequency.secs: 5
#supervisor.enable: true
ui.port: 8181
ui.childopts: "-Xmx256m"
logviewer.port: 8000
logviewer.childopts: "-Xmx128m"
logviewer.appender.name: "A1"
worker.childopts: "-Xmx512m -XX:MaxPermSize=256m -XX:+PrintGCDetails
-XX:+PrintGCTimeStamps -verbose:gc
-Xloggc:/app/local/var/logs/jvm-stat/gc-storm-worker-%ID%.log"
worker.heartbeat.frequency.secs: 1
task.heartbeat.frequency.secs: 3
task.refresh.poll.secs: 10
#zmq.threads: 1
#zmq.linger.millis: 5000
#zmq.hwm: 0
storm.local.dir: "/ngs/app/isdbd/local/var/run/storm/data"
storm.local.mode.zmq: false
storm.cluster.mode: "distributed"
storm.thrift.transport: "backtype.storm.security.auth.SimpleTransportPlugin"
storm.messaging.transport: "backtype.storm.messaging.netty.Context"
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: 100
storm.messaging.netty.max_wait_ms: 1000
storm.messaging.netty.min_wait_ms: 500
java.library.path: "/usr/local/lib:/opt/local/lib:/usr/lib"
topology.enable.message.timeouts: true
topology.debug: false
topology.optimize: true
topology.workers: 5
topology.acker.executors: null
topology.tasks: null
topology.message.timeout.secs: 30
topology.skip.missing.kryo.registrations: false
topology.max.task.parallelism: null
topology.max.spout.pending: 20
topology.state.synchronization.timeout.secs: 60
topology.stats.sample.rate: 0.05
topology.builtin.metrics.bucket.size.secs: 60
topology.fall.back.on.java.serialization: true
topology.worker.childopts: "-Xmx512m"
topology.executor.receive.buffer.size: 1024
topology.executor.send.buffer.size: 1024
topology.receiver.buffer.size: 8
topology.transfer.buffer.size: 1024
topology.tick.tuple.freq.secs: null
topology.worker.shared.thread.pool.size: 4
topology.disruptor.wait.strategy: "com.lmax.disruptor.BlockingWaitStrategy"
topology.spout.wait.strategy: "backtype.storm.spout.SleepSpoutWaitStrategy"
topology.sleep.spout.wait.strategy.time.ms: 1
topology.error.throttle.interval.secs: 10
topology.max.error.report.per.interval: 5
topology.kryo.factory: "backtype.storm.serialization.DefaultKryoFactory"
topology.tuple.serializer:
"backtype.storm.serialization.types.ListDelegateSerializer"
topology.trident.batch.emit.interval.millis: 500
#dev.zookeeper.path: "/tmp/dev-storm-zookeeper"
Re: java.lang.IllegalArgumentException: timeout value is negative
Posted by P Ghosh <ja...@gmail.com>.
Thanks Srinath for that ref.
Prasun
On Tue, Jun 3, 2014 at 5:41 PM, Srinath C <sr...@gmail.com> wrote:
> There is a known bug - https://issues.apache.org/jira/browse/STORM-187
>
>
>
> On Wed, Jun 4, 2014 at 1:38 AM, P Ghosh <ja...@gmail.com> wrote:
>
>> I'm getting this exception
>> 2014-06-03 19:59:13 STDIO [ERROR][id:] Jun 03, 2014 7:59:13 PM
>> org.jboss.netty.channel.DefaultChannelPipeline
>> WARNING: An exception was thrown by a user handler while handling an
>> exception event ([id: 0xdcf3be42] EXCEPTION: java.net.ConnectException:
>> Connection refused)
>> java.lang.IllegalArgumentException: timeout value is negative
>> at java.lang.Thread.sleep(Native Method)
>> at backtype.storm.messaging.netty.Client.reconnect(Client.java:94)
>> at
>> backtype.storm.messaging.netty.StormClientHandler.exceptionCaught(StormClientHandler.java:118)
>> at
>> org.jboss.netty.handler.codec.frame.FrameDecoder.exceptionCaught(FrameDecoder.java:377)
>>
>>
>> *Here's my storm.yaml (from nimbus/zookeeper only server.... hence ports
>> are commented)*
>> storm.zookeeper.servers:
>> - "ma-app05.corp.mydomain.com"
>> storm.zookeeper.port: 2181
>> storm.zookeeper.root: "/storm"
>> storm.zookeeper.session.timeout: 20000
>> storm.zookeeper.connection.timeout: 15000
>> storm.zookeeper.retry.times: 5
>> storm.zookeeper.retry.interval: 1000
>> storm.zookeeper.retry.intervalceiling.millis: 30000
>>
>>
>> nimbus.host: "ma-app05.corp.mydomain.com"
>> nimbus.thrift.port: 6627
>> nimbus.thrift.max_buffer_size: 1048576
>> nimbus.childopts: "-Xmx1024m"
>> nimbus.task.timeout.secs: 30
>> nimbus.supervisor.timeout.secs: 60
>> nimbus.monitor.freq.secs: 10
>> nimbus.cleanup.inbox.freq.secs: 600
>> nimbus.inbox.jar.expiration.secs: 3600
>> nimbus.task.launch.secs: 120
>> nimbus.reassign: true
>> nimbus.file.copy.expiration.secs: 600
>> nimbus.topology.validator:
>> "backtype.storm.nimbus.DefaultTopologyValidator"
>>
>> #No supervisor in Nimbus. Pls. note that storm might still be loading the
>> default conf, if it requires.
>> #supervisor.slots.ports:
>> # - 9951
>> # - 9952
>> # - 9953
>> # - 9954
>> # - 9955
>> #supervisor.worker.start.timeout.secs: 120
>> #supervisor.worker.timeout.secs: 30
>> #supervisor.monitor.frequency.secs: 3
>> #supervisor.heartbeat.frequency.secs: 5
>> #supervisor.enable: true
>>
>>
>> ui.port: 8181
>> ui.childopts: "-Xmx256m"
>>
>>
>> logviewer.port: 8000
>> logviewer.childopts: "-Xmx128m"
>> logviewer.appender.name: "A1"
>>
>> worker.childopts: "-Xmx512m -XX:MaxPermSize=256m -XX:+PrintGCDetails
>> -XX:+PrintGCTimeStamps -verbose:gc
>> -Xloggc:/app/local/var/logs/jvm-stat/gc-storm-worker-%ID%.log"
>> worker.heartbeat.frequency.secs: 1
>>
>> task.heartbeat.frequency.secs: 3
>> task.refresh.poll.secs: 10
>>
>> #zmq.threads: 1
>> #zmq.linger.millis: 5000
>> #zmq.hwm: 0
>>
>> storm.local.dir: "/ngs/app/isdbd/local/var/run/storm/data"
>>
>> storm.local.mode.zmq: false
>>
>>
>> storm.cluster.mode: "distributed"
>>
>> storm.thrift.transport:
>> "backtype.storm.security.auth.SimpleTransportPlugin"
>>
>> storm.messaging.transport: "backtype.storm.messaging.netty.Context"
>> 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: 100
>> storm.messaging.netty.max_wait_ms: 1000
>> storm.messaging.netty.min_wait_ms: 500
>>
>> java.library.path: "/usr/local/lib:/opt/local/lib:/usr/lib"
>>
>> topology.enable.message.timeouts: true
>> topology.debug: false
>> topology.optimize: true
>> topology.workers: 5
>> topology.acker.executors: null
>> topology.tasks: null
>> topology.message.timeout.secs: 30
>> topology.skip.missing.kryo.registrations: false
>> topology.max.task.parallelism: null
>> topology.max.spout.pending: 20
>> topology.state.synchronization.timeout.secs: 60
>> topology.stats.sample.rate: 0.05
>> topology.builtin.metrics.bucket.size.secs: 60
>> topology.fall.back.on.java.serialization: true
>> topology.worker.childopts: "-Xmx512m"
>> topology.executor.receive.buffer.size: 1024
>>
>> topology.executor.send.buffer.size: 1024
>>
>> topology.receiver.buffer.size: 8
>>
>> topology.transfer.buffer.size: 1024
>>
>> topology.tick.tuple.freq.secs: null
>> topology.worker.shared.thread.pool.size: 4
>> topology.disruptor.wait.strategy:
>> "com.lmax.disruptor.BlockingWaitStrategy"
>> topology.spout.wait.strategy:
>> "backtype.storm.spout.SleepSpoutWaitStrategy"
>> topology.sleep.spout.wait.strategy.time.ms: 1
>> topology.error.throttle.interval.secs: 10
>> topology.max.error.report.per.interval: 5
>> topology.kryo.factory: "backtype.storm.serialization.DefaultKryoFactory"
>> topology.tuple.serializer:
>> "backtype.storm.serialization.types.ListDelegateSerializer"
>> topology.trident.batch.emit.interval.millis: 500
>>
>> #dev.zookeeper.path: "/tmp/dev-storm-zookeeper"
>>
>>
>>
>
Re: java.lang.IllegalArgumentException: timeout value is negative
Posted by Srinath C <sr...@gmail.com>.
There is a known bug - https://issues.apache.org/jira/browse/STORM-187
On Wed, Jun 4, 2014 at 1:38 AM, P Ghosh <ja...@gmail.com> wrote:
> I'm getting this exception
> 2014-06-03 19:59:13 STDIO [ERROR][id:] Jun 03, 2014 7:59:13 PM
> org.jboss.netty.channel.DefaultChannelPipeline
> WARNING: An exception was thrown by a user handler while handling an
> exception event ([id: 0xdcf3be42] EXCEPTION: java.net.ConnectException:
> Connection refused)
> java.lang.IllegalArgumentException: timeout value is negative
> at java.lang.Thread.sleep(Native Method)
> at backtype.storm.messaging.netty.Client.reconnect(Client.java:94)
> at
> backtype.storm.messaging.netty.StormClientHandler.exceptionCaught(StormClientHandler.java:118)
> at
> org.jboss.netty.handler.codec.frame.FrameDecoder.exceptionCaught(FrameDecoder.java:377)
>
>
> *Here's my storm.yaml (from nimbus/zookeeper only server.... hence ports
> are commented)*
> storm.zookeeper.servers:
> - "ma-app05.corp.mydomain.com"
> storm.zookeeper.port: 2181
> storm.zookeeper.root: "/storm"
> storm.zookeeper.session.timeout: 20000
> storm.zookeeper.connection.timeout: 15000
> storm.zookeeper.retry.times: 5
> storm.zookeeper.retry.interval: 1000
> storm.zookeeper.retry.intervalceiling.millis: 30000
>
>
> nimbus.host: "ma-app05.corp.mydomain.com"
> nimbus.thrift.port: 6627
> nimbus.thrift.max_buffer_size: 1048576
> nimbus.childopts: "-Xmx1024m"
> nimbus.task.timeout.secs: 30
> nimbus.supervisor.timeout.secs: 60
> nimbus.monitor.freq.secs: 10
> nimbus.cleanup.inbox.freq.secs: 600
> nimbus.inbox.jar.expiration.secs: 3600
> nimbus.task.launch.secs: 120
> nimbus.reassign: true
> nimbus.file.copy.expiration.secs: 600
> nimbus.topology.validator: "backtype.storm.nimbus.DefaultTopologyValidator"
>
> #No supervisor in Nimbus. Pls. note that storm might still be loading the
> default conf, if it requires.
> #supervisor.slots.ports:
> # - 9951
> # - 9952
> # - 9953
> # - 9954
> # - 9955
> #supervisor.worker.start.timeout.secs: 120
> #supervisor.worker.timeout.secs: 30
> #supervisor.monitor.frequency.secs: 3
> #supervisor.heartbeat.frequency.secs: 5
> #supervisor.enable: true
>
>
> ui.port: 8181
> ui.childopts: "-Xmx256m"
>
>
> logviewer.port: 8000
> logviewer.childopts: "-Xmx128m"
> logviewer.appender.name: "A1"
>
> worker.childopts: "-Xmx512m -XX:MaxPermSize=256m -XX:+PrintGCDetails
> -XX:+PrintGCTimeStamps -verbose:gc
> -Xloggc:/app/local/var/logs/jvm-stat/gc-storm-worker-%ID%.log"
> worker.heartbeat.frequency.secs: 1
>
> task.heartbeat.frequency.secs: 3
> task.refresh.poll.secs: 10
>
> #zmq.threads: 1
> #zmq.linger.millis: 5000
> #zmq.hwm: 0
>
> storm.local.dir: "/ngs/app/isdbd/local/var/run/storm/data"
>
> storm.local.mode.zmq: false
>
>
> storm.cluster.mode: "distributed"
>
> storm.thrift.transport:
> "backtype.storm.security.auth.SimpleTransportPlugin"
>
> storm.messaging.transport: "backtype.storm.messaging.netty.Context"
> 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: 100
> storm.messaging.netty.max_wait_ms: 1000
> storm.messaging.netty.min_wait_ms: 500
>
> java.library.path: "/usr/local/lib:/opt/local/lib:/usr/lib"
>
> topology.enable.message.timeouts: true
> topology.debug: false
> topology.optimize: true
> topology.workers: 5
> topology.acker.executors: null
> topology.tasks: null
> topology.message.timeout.secs: 30
> topology.skip.missing.kryo.registrations: false
> topology.max.task.parallelism: null
> topology.max.spout.pending: 20
> topology.state.synchronization.timeout.secs: 60
> topology.stats.sample.rate: 0.05
> topology.builtin.metrics.bucket.size.secs: 60
> topology.fall.back.on.java.serialization: true
> topology.worker.childopts: "-Xmx512m"
> topology.executor.receive.buffer.size: 1024
>
> topology.executor.send.buffer.size: 1024
>
> topology.receiver.buffer.size: 8
>
> topology.transfer.buffer.size: 1024
>
> topology.tick.tuple.freq.secs: null
> topology.worker.shared.thread.pool.size: 4
> topology.disruptor.wait.strategy: "com.lmax.disruptor.BlockingWaitStrategy"
> topology.spout.wait.strategy: "backtype.storm.spout.SleepSpoutWaitStrategy"
> topology.sleep.spout.wait.strategy.time.ms: 1
> topology.error.throttle.interval.secs: 10
> topology.max.error.report.per.interval: 5
> topology.kryo.factory: "backtype.storm.serialization.DefaultKryoFactory"
> topology.tuple.serializer:
> "backtype.storm.serialization.types.ListDelegateSerializer"
> topology.trident.batch.emit.interval.millis: 500
>
> #dev.zookeeper.path: "/tmp/dev-storm-zookeeper"
>
>
>