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

spark-user | donhoff_h | 2 years ago
  1. 0

    meet weird exception when studying rdd caching

    spark-user | 2 years ago | donhoff_h
    java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
  2. 0

    GitHub comment 1378#260816383

    GitHub | 3 weeks ago | davidmarin
    java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
  3. 0

    2.2.3 Noisy shutdown w/exception

    Google Groups | 3 years ago | tigerfoot
    java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    GitHub comment 3317#191659623

    GitHub | 9 months ago | benjaminrigaud
    java.util.concurrent.RejectedExecutionException: Worker has already been shutdown
  6. 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

    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
      AbstractChannel.disconnect
      1. org.jboss.netty.channel.socket.nio.AbstractNioSelector.registerTask(AbstractNioSelector.java:120)
      2. org.jboss.netty.channel.socket.nio.AbstractNioWorker.executeInIoThread(AbstractNioWorker.java:72)
      3. org.jboss.netty.channel.socket.nio.NioWorker.executeInIoThread(NioWorker.java:36)
      4. org.jboss.netty.channel.socket.nio.AbstractNioWorker.executeInIoThread(AbstractNioWorker.java:56)
      5. org.jboss.netty.channel.socket.nio.NioWorker.executeInIoThread(NioWorker.java:36)
      6. org.jboss.netty.channel.socket.nio.AbstractNioChannelSink.execute(AbstractNioChannelSink.java:34)
      7. org.jboss.netty.channel.Channels.fireExceptionCaughtLater(Channels.java:496)
      8. org.jboss.netty.channel.AbstractChannelSink.exceptionCaught(AbstractChannelSink.java:46)
      9. org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
      10. org.jboss.netty.channel.Channels.disconnect(Channels.java:781)
      11. org.jboss.netty.channel.AbstractChannel.disconnect(AbstractChannel.java:211)
      11 frames
    3. Akka Remote
      NettyTransport$$anonfun$gracefulClose$1.apply
      1. akka.remote.transport.netty.NettyTransport$$anonfun$gracefulClose$1.apply(NettyTransport.scala:223)
      2. akka.remote.transport.netty.NettyTransport$$anonfun$gracefulClose$1.apply(NettyTransport.scala:222)
      2 frames
    4. Scala
      CallbackRunnable.run
      1. scala.util.Success.foreach(Try.scala:205)
      2. scala.concurrent.Future$$anonfun$foreach$1.apply(Future.scala:204)
      3. scala.concurrent.Future$$anonfun$foreach$1.apply(Future.scala:204)
      4. scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
      4 frames
    5. Akka Actor
      BatchingExecutor$Batch$$anonfun$run$1.apply
      1. akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67)
      2. akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82)
      3. akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59)
      4. akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59)
      4 frames
    6. Scala
      BlockContext$.withBlockContext
      1. scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
      1 frame
    7. Akka Actor
      ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec
      1. akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58)
      2. akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
      3. akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
      3 frames
    8. Scala
      ForkJoinWorkerThread.run
      1. scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
      2. scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
      3. scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
      4. scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
      4 frames