java.lang.RuntimeException: java.lang.RuntimeException: Client is being closed, and does not take requests any more

Apache's JIRA Issue Tracker | Sean Zhong | 3 years ago
  1. 0

    storm集群 + kafka单机性能测试

    sxt.cn | 5 months ago
    java.lang.RuntimeException: java.lang.RuntimeException: Client is being closed, and does not take requests any more
  2. Speed up your debug routine!

    Automated exception search integrated into your IDE

  3. 0

    I have two workers (one on each machine). The first worker(10.30.206.125) had a problem starting (could not find Nimbus host), however the second worker crashed too since it could not connect to the first worker. This looks like a cascading failure, which seems like a bug. {code} 2014-07-15 17:43:32 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [17] 2014-07-15 17:43:33 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [18] 2014-07-15 17:43:34 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [19] 2014-07-15 17:43:35 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [20] 2014-07-15 17:43:36 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [21] 2014-07-15 17:43:37 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [22] 2014-07-15 17:43:38 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [23] 2014-07-15 17:43:39 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [24] 2014-07-15 17:43:40 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [25] 2014-07-15 17:43:41 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [26] 2014-07-15 17:43:42 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [27] 2014-07-15 17:43:43 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [28] 2014-07-15 17:43:44 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [29] 2014-07-15 17:43:45 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700... [30] 2014-07-15 17:43:46 b.s.m.n.Client [INFO] Closing Netty Client Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700 2014-07-15 17:43:46 b.s.m.n.Client [INFO] Waiting for pending batchs to be sent with Netty-Client-ip-10-30-206-125.ec2.internal/10.30.206.125:6700..., timeout: 600000ms, pendings: 0 2014-07-15 17:43:46 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:128) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.disruptor$consume_loop_STAR_$fn__758.invoke(disruptor.clj:94) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.util$async_loop$fn__457.invoke(util.clj:431) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_60] 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:194) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.utils.TransferDrainer.send(TransferDrainer.java:54) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.daemon.worker$mk_transfer_tuples_handler$fn__5927$fn__5928.invoke(worker.clj:322) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.daemon.worker$mk_transfer_tuples_handler$fn__5927.invoke(worker.clj:320) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.disruptor$clojure_handler$reify__745.onEvent(disruptor.clj:58) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:125) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] ... 6 common frames omitted 2014-07-15 17:43:46 b.s.util [INFO] Halting process: ("Async loop died!") {code}

    Apache's JIRA Issue Tracker | 2 years ago | Itai Frenkel
    java.lang.RuntimeException: java.lang.RuntimeException: Client is being closed, and does not take requests any more
  4. 0

    GitHub comment 26#119153049

    GitHub | 1 year ago | cuiqin
    java.lang.RuntimeException: java.lang.RuntimeException: Client is being closed, and does not take requests any more

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.RuntimeException

      Client is being closed, and does not take requests any more

      at backtype.storm.messaging.netty.Client.send()
    2. backtype.storm.messaging
      Client.send
      1. backtype.storm.messaging.netty.Client.send(Client.java:194)[classes/:na]
      1 frame
    3. backtype.storm.utils
      TransferDrainer.send
      1. backtype.storm.utils.TransferDrainer.send(TransferDrainer.java:54)[classes/:na]
      1 frame
    4. backtype.storm.daemon
      worker$mk_transfer_tuples_handler$fn__5765.invoke
      1. backtype.storm.daemon.worker$mk_transfer_tuples_handler$fn__5765$fn__5766.invoke(worker.clj:322)[classes/:na]
      2. backtype.storm.daemon.worker$mk_transfer_tuples_handler$fn__5765.invoke(worker.clj:320)[classes/:na]
      2 frames
    5. backtype.storm
      disruptor$clojure_handler$reify__2882.onEvent
      1. backtype.storm.disruptor$clojure_handler$reify__2882.onEvent(disruptor.clj:59)[classes/:na]
      1 frame
    6. backtype.storm.utils
      DisruptorQueue.consumeBatchWhenAvailable
      1. backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:111)[classes/:na]
      2. backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:85)[classes/:na]
      2 frames
    7. backtype.storm
      util$async_loop$fn__442.invoke
      1. backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:78)[classes/:na]
      2. backtype.storm.disruptor$consume_loop_STAR_$fn__2895.invoke(disruptor.clj:89)[classes/:na]
      3. backtype.storm.util$async_loop$fn__442.invoke(util.clj:434)[classes/:na]
      3 frames
    8. Clojure
      AFn.run
      1. clojure.lang.AFn.run(AFn.java:24)[clojure-1.4.0.jar:na]
      1 frame
    9. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:679)[na:1.6.0_22]
      1 frame