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

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

• A patch is available from the attached files:
  • com.sos-berlin.jobscheduler.engine.engine-common-1.12.10-SNAPSHOT.jar
  • com.sos-berlin.jobscheduler.engine.engine-tunnel-1.12.10-SNAPSHOT.jar
• or from https://download.sos-berlin.com/patches/patch-20190620-JS-1845-1.12.7-1.12.8.zip
• Store both .jar files to the ./lib/patches directory and restart the Agent to apply the patch