java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException: Worker has already been shutdown

Apache's JIRA Issue Tracker | Jaehwa Jung | 2 years ago
  1. 0

    NettyClientBase throws RejectedExecutionException occasionally. For example, add following simple codes to unit test cases. {code:xml} @Test public final void testShutdownCluster() throws Exception { TajoTestingCluster activeMaster = new TajoTestingCluster(); activeMaster.startMiniCluster(1); activeMaster.shutdownMiniCluster(); } {code} If you added above codes, run 'mvn clean install', and then you can find infinite loop as follows: {code:xml} 2014-07-15 10:36:12,217 ERROR: org.apache.tajo.rpc.AsyncRpcClient (exceptionCaught(235)) - RPC Exception:java.util.concurrent.RejectedExecutionException: Worker has already been shutdown 2014-07-15 10:36:12,218 ERROR: org.apache.tajo.worker.WorkerHeartbeatService (run(241)) - java.util.concurrent.RejectedExecutionException: Worker has already been shutdown java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException: Worker has already been shutdown at org.apache.tajo.rpc.NettyClientBase.connect(NettyClientBase.java:93) at org.apache.tajo.rpc.RpcConnectionPool.getConnection(RpcConnectionPool.java:89) at org.apache.tajo.worker.WorkerHeartbeatService$WorkerHeartbeatThread.run(WorkerHeartbeatService.java:220) Caused by: java.util.concurrent.RejectedExecutionException: Worker has already been shutdown at org.jboss.netty.channel.socket.nio.AbstractNioSelector.registerTask(AbstractNioSelector.java:115) at org.jboss.netty.channel.socket.nio.AbstractNioSelector.register(AbstractNioSelector.java:100) at org.jboss.netty.channel.socket.nio.NioClientBoss.register(NioClientBoss.java:42) at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:121) at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70) at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54) at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54) at org.jboss.netty.channel.Channels.connect(Channels.java:634) at org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207) at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229) at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182) at org.apache.tajo.rpc.NettyClientBase.connect(NettyClientBase.java:76) {code}

    Apache's JIRA Issue Tracker | 2 years ago | Jaehwa Jung
    java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
  2. 0

    Neo4j 2.1.7-SNAPSHOT build failure at HA tests

    Stack Overflow | 2 years ago | stesin
    java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
  3. 0

    GitHub comment 3317#191659623

    GitHub | 9 months ago | benjaminrigaud
    java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    2.2.3 Noisy shutdown w/exception

    Google Groups | 3 years ago | tigerfoot
    java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
  6. 0

    OOM -> LockObtainFailedException -> All data lost

    GitHub | 4 months ago | DaveChapman
    java.util.concurrent.RejectedExecutionException: Worker has already been shutdown

    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.util.concurrent.RejectedExecutionException

      Worker has already been shutdown

      at org.jboss.netty.channel.socket.nio.AbstractNioSelector.registerTask()
    2. Netty
      ClientBootstrap.connect
      1. org.jboss.netty.channel.socket.nio.AbstractNioSelector.registerTask(AbstractNioSelector.java:115)
      2. org.jboss.netty.channel.socket.nio.AbstractNioSelector.register(AbstractNioSelector.java:100)
      3. org.jboss.netty.channel.socket.nio.NioClientBoss.register(NioClientBoss.java:42)
      4. org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:121)
      5. org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70)
      6. org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
      7. org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
      8. org.jboss.netty.channel.Channels.connect(Channels.java:634)
      9. org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
      10. org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
      11. org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
      11 frames
    3. org.apache.tajo
      NettyClientBase.connect
      1. org.apache.tajo.rpc.NettyClientBase.connect(NettyClientBase.java:76)
      1 frame