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

Google Groups | tigerfoot | 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

    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 | 3 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