See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/1567/display/redirect?page=changes>
Changes:
[lcwik] [BEAM-6194] Follow up with cleanup for
------------------------------------------
[...truncated 495.08 KB...]
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:461)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:483)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282)
at akka.dispatch.Mailbox.run(Mailbox.scala:223)
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)
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedConstructorAccessor19.newInstance(Unknown
Source)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at akka.util.Reflect$.instantiate(Reflect.scala:65)
at
akka.actor.ArgsReflectConstructor.produce(IndirectActorProducer.scala:96)
at akka.actor.Props.newActor(Props.scala:213)
at akka.actor.ActorCell.newActor(ActorCell.scala:562)
at akka.actor.ActorCell.create(ActorCell.scala:588)
... 9 more
Caused by: akka.actor.InvalidActorNameException: actor name [netty-server]
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.attachChild(Children.scala:46)
at akka.actor.ActorCell.attachChild(ActorCell.scala:374)
at akka.actor.ActorSystemImpl.actorOf(ActorSystem.scala:729)
at org.apache.gearpump.transport.netty.Context.bind(Context.scala:72)
at
org.apache.gearpump.transport.Express.init$lzycompute(Express.scala:61)
at org.apache.gearpump.transport.Express.init(Express.scala:58)
at
org.apache.gearpump.transport.Express.registerLocalActor(Express.scala:103)
at
org.apache.gearpump.streaming.task.TaskActor.<init>(TaskActor.scala:91)
... 17 more
Dec 07, 2018 7:26:03 PM
org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(1,0) fails too many times to recover
Dec 07, 2018 7:26:03 PM org.apache.gearpump.transport.Express
init$lzycompute
INFO: Start Express init ...master
Dec 07, 2018 7:26:03 PM
org.apache.gearpump.streaming.executor.Executor$$anonfun$1 applyOrElse
SEVERE: We got akka.actor.ActorInitializationException from
Some(TaskId(0,0)), we will treat it as MessageLoss, so that the system will
replay all lost message
akka.actor.ActorInitializationException:
akka://master/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors/0/processor_0_task_0:
exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:174)
at akka.actor.ActorCell.create(ActorCell.scala:607)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:461)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:483)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282)
at akka.dispatch.Mailbox.run(Mailbox.scala:223)
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)
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedConstructorAccessor19.newInstance(Unknown
Source)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at akka.util.Reflect$.instantiate(Reflect.scala:65)
at
akka.actor.ArgsReflectConstructor.produce(IndirectActorProducer.scala:96)
at akka.actor.Props.newActor(Props.scala:213)
at akka.actor.ActorCell.newActor(ActorCell.scala:562)
at akka.actor.ActorCell.create(ActorCell.scala:588)
... 9 more
Caused by: java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:717)
at
java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:957)
at
java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1378)
at
org.jboss.netty.util.internal.DeadLockProofWorker.start(DeadLockProofWorker.java:38)
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.openSelector(AbstractNioSelector.java:349)
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.<init>(AbstractNioSelector.java:100)
at
org.jboss.netty.channel.socket.nio.NioServerBoss.<init>(NioServerBoss.java:49)
at
org.jboss.netty.channel.socket.nio.NioServerBossPool.newBoss(NioServerBossPool.java:55)
at
org.jboss.netty.channel.socket.nio.NioServerBossPool.newBoss(NioServerBossPool.java:26)
at
org.jboss.netty.channel.socket.nio.AbstractNioBossPool.init(AbstractNioBossPool.java:75)
at
org.jboss.netty.channel.socket.nio.NioServerBossPool.<init>(NioServerBossPool.java:40)
at
org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory.<init>(NioServerSocketChannelFactory.java:179)
at
org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory.<init>(NioServerSocketChannelFactory.java:149)
at
org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory.<init>(NioServerSocketChannelFactory.java:131)
at
org.apache.gearpump.transport.netty.NettyUtil$.newNettyServer(NettyUtil.scala:37)
at org.apache.gearpump.transport.netty.Context.bind(Context.scala:74)
at
org.apache.gearpump.transport.Express.init$lzycompute(Express.scala:61)
at org.apache.gearpump.transport.Express.init(Express.scala:58)
at
org.apache.gearpump.transport.Express.registerLocalActor(Express.scala:103)
at
org.apache.gearpump.streaming.task.TaskActor.<init>(TaskActor.scala:91)
... 17 more
Dec 07, 2018 7:26:03 PM
akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2
apply$mcV$sp
WARNING: actor name [netty-server] is not unique!
Dec 07, 2018 7:26:03 PM
akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2
apply$mcV$sp
WARNING: actor name [netty-server] is not unique!
Uncaught error from thread [master-akka.actor.default-dispatcher-4]
shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for
ActorSystem[master]
Uncaught error from thread [master-akka.actor.default-dispatcher-3]
shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for
ActorSystem[master]
Dec 07, 2018 7:26:03 PM
org.apache.gearpump.streaming.executor.Executor$$anonfun$1 applyOrElse
SEVERE: We got akka.actor.ActorInitializationException from
Some(TaskId(2,0)), we will treat it as MessageLoss, so that the system will
replay all lost message
akka.actor.ActorInitializationException:
akka://master/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors/0/processor_2_task_0:
exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:174)
at akka.actor.ActorCell.create(ActorCell.scala:607)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:461)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:483)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282)
at akka.dispatch.Mailbox.run(Mailbox.scala:223)
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)
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedConstructorAccessor19.newInstance(Unknown
Source)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at akka.util.Reflect$.instantiate(Reflect.scala:65)
at
akka.actor.ArgsReflectConstructor.produce(IndirectActorProducer.scala:96)
at akka.actor.Props.newActor(Props.scala:213)
at akka.actor.ActorCell.newActor(ActorCell.scala:562)
at akka.actor.ActorCell.create(ActorCell.scala:588)
... 9 more
Caused by: akka.actor.InvalidActorNameException: actor name [netty-server]
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.attachChild(Children.scala:46)
at akka.actor.ActorCell.attachChild(ActorCell.scala:374)
at akka.actor.ActorSystemImpl.actorOf(ActorSystem.scala:729)
at org.apache.gearpump.transport.netty.Context.bind(Context.scala:72)
at
org.apache.gearpump.transport.Express.init$lzycompute(Express.scala:61)
at org.apache.gearpump.transport.Express.init(Express.scala:58)
at
org.apache.gearpump.transport.Express.registerLocalActor(Express.scala:103)
at
org.apache.gearpump.streaming.task.TaskActor.<init>(TaskActor.scala:91)
... 17 more
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:717)
at
scala.concurrent.forkjoin.ForkJoinPool.tryAddWorker(ForkJoinPool.java:1672)
Dec 07, 2018 7:26:03 PM org.apache.gearpump.transport.Express
registerLocalActor
INFO: RegisterLocalActor: 0, actor: processor_0_task_0
Dec 07, 2018 7:26:03 PM org.apache.gearpump.transport.Express
registerLocalActor
INFO: RegisterLocalActor: 4294967296, actor: processor_1_task_0
Dec 07, 2018 7:26:03 PM org.apache.gearpump.transport.Express
registerLocalActor
INFO: RegisterLocalActor: 21474836480, actor: processor_5_task_0
at
scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
Dec 07, 2018 7:26:03 PM org.apache.gearpump.transport.Express
init$lzycompute
INFO: Start Express init ...master
Dec 07, 2018 7:26:03 PM
org.apache.gearpump.streaming.executor.Executor$$anonfun$1 applyOrElse
SEVERE: We got akka.actor.ActorInitializationException from None, we will
treat it as MessageLoss, so that the system will replay all lost message
akka.actor.ActorInitializationException:
akka://master/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors/0/processor_4_task_0:
exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:174)
at akka.actor.ActorCell.create(ActorCell.scala:607)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:461)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:483)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282)
at akka.dispatch.Mailbox.run(Mailbox.scala:223)
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)
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedConstructorAccessor19.newInstance(Unknown
Source)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at akka.util.Reflect$.instantiate(Reflect.scala:65)
at
akka.actor.ArgsReflectConstructor.produce(IndirectActorProducer.scala:96)
at akka.actor.Props.newActor(Props.scala:213)
at akka.actor.ActorCell.newActor(ActorCell.scala:562)
at akka.actor.ActorCell.create(ActorCell.scala:588)
... 9 more
Caused by: akka.actor.InvalidActorNameException: actor name [netty-server]
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.attachChild(Children.scala:46)
at akka.actor.ActorCell.attachChild(ActorCell.scala:374)
at akka.actor.ActorSystemImpl.actorOf(ActorSystem.scala:729)
at org.apache.gearpump.transport.netty.Context.bind(Context.scala:72)
at
org.apache.gearpump.transport.Express.init$lzycompute(Express.scala:61)
at org.apache.gearpump.transport.Express.init(Express.scala:58)
at
org.apache.gearpump.transport.Express.registerLocalActor(Express.scala:103)
at
org.apache.gearpump.streaming.task.TaskActor.<init>(TaskActor.scala:91)
... 17 more
Dec 07, 2018 7:26:03 PM org.apache.gearpump.transport.Express
init$lzycompute
INFO: Start Express init ...master
Dec 07, 2018 7:26:03 PM org.apache.gearpump.transport.Express
init$lzycompute
INFO: Start Express init ...master
at
scala.concurrent.forkjoin.ForkJoinPool.externalPush(ForkJoinPool.java:1829)
at
scala.concurrent.forkjoin.ForkJoinPool.execute(ForkJoinPool.java:2955)
at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool.execute(AbstractDispatcher.scala:401)
at
akka.dispatch.ExecutorServiceDelegate$class.execute(ThreadPoolBuilder.scala:211)
at
akka.dispatch.Dispatcher$LazyExecutorServiceDelegate.execute(Dispatcher.scala:39)
at akka.dispatch.Dispatcher.registerForExecution(Dispatcher.scala:115)
at akka.dispatch.MessageDispatcher.attach(AbstractDispatcher.scala:133)
at akka.actor.dungeon.Dispatch$class.start(Dispatch.scala:100)
at akka.actor.ActorCell.start(ActorCell.scala:374)
at akka.actor.LocalActorRef.start(ActorRef.scala:343)
at akka.actor.dungeon.Children$class.makeChild(Children.scala:287)
at akka.actor.dungeon.Children$class.actorOf(Children.scala:42)
at akka.actor.ActorCell.actorOf(ActorCell.scala:374)
at
org.apache.gearpump.streaming.executor.TaskLauncher.launch(TaskLauncher.scala:63)
at
org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1.applyOrElse(Executor.scala:156)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at akka.actor.Actor$class.aroundReceive(Actor.scala:496)
at
org.apache.gearpump.streaming.executor.Executor.aroundReceive(Executor.scala:54)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
Dec 07, 2018 7:26:03 PM org.apache.gearpump.transport.Express
registerLocalActor
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)
org.apache.beam.sdk.testing.PAssertTest > testIsEqualTo SKIPPED
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Daemon worker,5,main])
completed. Took 30.293 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 255
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at
https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1m 51s
36 actionable tasks: 32 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/qtxlvgiptu5rs
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
