Uploaded image for project: 'JS - JobScheduler'
  1. JS - JobScheduler
  2. JS-1845

For a large number of tasks JobScheduler Universal Agent throws an error akka.actor.OneForOneStrategy - actor name [actor-name] is not unique

    XMLWordPrintable

    Details

      Description

      Current Situation

      • the customer has a large number of tasks running on JobScheduler universal agent.
      • intermittently agent throws an error  [ERROR] akka.actor.OneForOneStrategy - actor name [Connector-TCP-127.0.0.1:46212] is not unique!
      • 2019-06-10 01:09:44,236 +0200 [ERROR] akka.actor.OneForOneStrategy - actor name [Connector-TCP-127.0.0.1:46212] is not unique!akka.actor.InvalidActorNameException: actor name [Connector-TCP-127.0.0.1:46212] is not unique!    at akka.actor.dungeon.ChildrenContainer$NormalChildrenContainer.reserve(ChildrenContainer.scala:129)    at akka.actor.dungeon.Children$class.reserveChild(Children.scala:130)    at akka.actor.ActorCell.reserveChild(ActorCell.scala:374)    at akka.actor.dungeon.Children$class.makeChild(Children.scala:268)    at akka.actor.dungeon.Children$class.actorOf(Children.scala:42)    at akka.actor.ActorCell.actorOf(ActorCell.scala:374)    at com.sos.scheduler.engine.tunnel.server.ConnectorHandler$$anonfun$com$sos$scheduler$engine$tunnel$server$ConnectorHandler$$ready$1.applyOrElse(ConnectorHandler.scala:61)    at akka.actor.Actor$class.aroundReceive(Actor.scala:502)    at com.sos.scheduler.engine.tunnel.server.ConnectorHandler.aroundReceive(ConnectorHandler.scala:24)    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)    at akka.actor.ActorCell.invoke(ActorCell.scala:495)    at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)    at akka.dispatch.Mailbox.run(Mailbox.scala:224)    at akka.dispatch.Mailbox.exec(Mailbox.scala:234)    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)2019-06-10 01:09:44,253 +0200 [INFO ] com.sos.scheduler.engine.taskserver.StandardTaskServer - (AgentTaskId(3566-3163304053661360202)) Terminated, java.io.IOException: Broken pipe2019-06-10 01:09:44,254 +0200 [ERROR] com.sos.scheduler.engine.taskserver.TaskServerMain - java.io.IOException: Broken pipejava.io.IOException: Broken pipe    at sun.nio.ch.FileDispatcherImpl.writev0(Native Method)    at sun.nio.ch.SocketDispatcher.writev(SocketDispatcher.java:51)    at sun.nio.ch.IOUtil.write(IOUtil.java:148)    at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:504)    at java.nio.channels.SocketChannel.write(SocketChannel.java:502)    at com.sos.scheduler.engine.common.tcp.BlockingTcpConnection.sendMessage(BlockingTcpConnection.scala:51)    at com.sos.scheduler.engine.common.tcp.BlockingTcpConnection.sendMessage(BlockingTcpConnection.scala:44)    at com.sos.scheduler.engine.minicom.remoting.dialog.StandardClientDialogConnection$$anonfun$sendAndReceive$1$$anonfun$apply$1$$anonfun$apply$2.apply(StandardClientDialogConnection.scala:20)    at com.sos.scheduler.engine.minicom.remoting.dialog.StandardClientDialogConnection$$anonfun$sendAndReceive$1$$anonfun$apply$1$$anonfun$apply$2.apply(StandardClientDialogConnection.scala:19)    at com.sos.scheduler.engine.minicom.remoting.dialog.ExclusiveLock$class.exclusive(ExclusiveLock.scala:17)    at com.sos.scheduler.engine.minicom.remoting.dialog.StandardServerDialogConnection.exclusive(StandardServerDialogConnection.scala:15)    at com.sos.scheduler.engine.minicom.remoting.dialog.StandardClientDialogConnection$$anonfun$sendAndReceive$1$$anonfun$apply$1.apply(StandardClientDialogConnection.scala:19)    at com.sos.scheduler.engine.minicom.remoting.dialog.StandardClientDialogConnection$$anonfun$sendAndReceive$1$$anonfun$apply$1.apply(StandardClientDialogConnection.scala:19)    at akka.dispatch.MonitorableThreadFactory$AkkaForkJoinWorkerThread$$anon$3.block(ThreadPoolBuilder.scala:167)    at scala.concurrent.forkjoin.ForkJoinPool.managedBlock(ForkJoinPool.java:3640)    at akka.dispatch.MonitorableThreadFactory$AkkaForkJoinWorkerThread.blockOn(ThreadPoolBuilder.scala:165)    at scala.concurrent.package$.blocking(package.scala:123)    at com.sos.scheduler.engine.minicom.remoting.dialog.StandardClientDialogConnection$$anonfun$sendAndReceive$1.apply(StandardClientDialogConnection.scala:18)    at com.sos.scheduler.engine.minicom.remoting.dialog.StandardClientDialogConnection$$anonfun$sendAndReceive$1.apply(StandardClientDialogConnection.scala:18)    at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)    at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)    at com.sos.scheduler.engine.base.utils.StackTraces$.newStackTrace(StackTraces.scala:42)    at com.sos.scheduler.engine.base.utils.StackTraces$StackTraceThrowable$.appendCurrentStackTrace$extension(StackTraces.scala:30)    at com.sos.scheduler.engine.common.scalautil.Futures$implicits$SuccessFuture$.successValue$extension(Futures.scala:65)    at com.sos.scheduler.engine.common.scalautil.Futures$implicits$SuccessFuture$.await$extension(Futures.scala:79)    at com.sos.scheduler.engine.taskserver.StandardTaskServer$$anonfun$start$1.apply$mcV$sp(StandardTaskServer.scala:63)    at com.sos.scheduler.engine.taskserver.StandardTaskServer$$anonfun$start$1.apply(StandardTaskServer.scala:60)    at com.sos.scheduler.engine.taskserver.StandardTaskServer$$anonfun$start$1.apply(StandardTaskServer.scala:60)    at scala.util.Try$.apply(Try.scala:192)    at com.sos.scheduler.engine.common.scalautil.Futures$$anon$1.run(Futures.scala:41)    at com.sos.scheduler.engine.base.utils.StackTraces$.newStackTrace(StackTraces.scala:42)    at com.sos.scheduler.engine.base.utils.StackTraces$StackTraceThrowable$.appendCurrentStackTrace$extension(StackTraces.scala:30)    at com.sos.scheduler.engine.common.scalautil.Futures$implicits$SuccessFuture$.successValue$extension(Futures.scala:65)    at com.sos.scheduler.engine.common.scalautil.Futures$.awaitResult(Futures.scala:25)    at com.sos.scheduler.engine.taskserver.TaskServerMain$$anonfun$run$1$$anonfun$apply$1.apply(TaskServerMain.scala:52)    at com.sos.scheduler.engine.taskserver.TaskServerMain$$anonfun$run$1$$anonfun$apply$1.apply(TaskServerMain.scala:49)    at com.sos.scheduler.engine.common.scalautil.AutoClosing$$anonfun$1.apply(AutoClosing.scala:26)    at com.sos.scheduler.engine.common.scalautil.AutoClosing$.closeOnError(AutoClosing.scala:34)    at com.sos.scheduler.engine.common.scalautil.AutoClosing$.autoClosing(AutoClosing.scala:25)    at com.sos.scheduler.engine.taskserver.TaskServerMain$$anonfun$run$1.apply(TaskServerMain.scala:49)    at com.sos.scheduler.engine.taskserver.TaskServerMain$$anonfun$run$1.apply(TaskServerMain.scala:46)    at com.sos.scheduler.engine.common.scalautil.AutoClosing$$anonfun$1.apply(AutoClosing.scala:26)    at com.sos.scheduler.engine.common.scalautil.AutoClosing$.closeOnError(AutoClosing.scala:34)    at com.sos.scheduler.engine.common.scalautil.AutoClosing$.autoClosing(AutoClosing.scala:25)    at com.sos.scheduler.engine.taskserver.TaskServerMain$.run(TaskServerMain.scala:46)    at com.sos.scheduler.engine.taskserver.TaskServerMain$.main(TaskServerMain.scala:30)    at com.sos.scheduler.engine.taskserver.TaskServerMain.main(TaskServerMain.scala)

      Desired Situation

      • The Universal Agent should not throw the error [ERROR] akka.actor.OneForOneStrategy - actor name [Connector-TCP-127.0.0.1:46212] is not unique!

      Patch

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                jz Joacim Zschimmer
                Reporter:
                mp Mahendra Patidar
                Approver:
                Mahendra Patidar
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: