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

Apache's JIRA Issue Tracker | Jaehwa Jung | 3 years ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  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 | 3 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

    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