Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-187

From ZMQ to Netty "java.lang.IllegalArgumentException: timeout value is negative"

    XMLWordPrintableJSON

Details

    Description

      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:

      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)
      

      I am using the following supervisor config:

      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
      

      Without these last config lines, topologies are working fine using ZMQ.

      Any idea?

      Thanks

      Attachments

        1. STORM-187.patch
          2 kB
          P. Taylor Goetz

        Activity

          People

            ptgoetz P. Taylor Goetz
            jihonrado Jose Ignacio Honrado
            Votes:
            2 Vote for this issue
            Watchers:
            10 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: