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

Google Groups | tigerfoot | 3 years ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    2.2.3 Noisy shutdown w/exception

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

    meet weird exception when studying rdd caching

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

    GitHub comment 1378#260816383

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

    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:115)
      2. org.jboss.netty.channel.socket.nio.AbstractNioWorker.executeInIoThread(AbstractNioWorker.java:73)
      3. org.jboss.netty.channel.socket.nio.NioWorker.executeInIoThread(NioWorker.java:36)
      4. org.jboss.netty.channel.socket.nio.AbstractNioWorker.executeInIoThread(AbstractNioWorker.java:57)
      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:222)
      2. akka.remote.transport.netty.NettyTransport$$anonfun$gracefulClose$1.apply(NettyTransport.scala:221)
      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:42)
      3. akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386)
      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