You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/12/26 15:26:47 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump #1737
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/1737/display/redirect?page=changes>
Changes:
[iemejia] BEAM-6306 Upgrade Jackson to version 2.9.8
------------------------------------------
[...truncated 1.27 MB...]
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)
Caused by: java.lang.AssertionError: Create.Values/Read(CreateSource).out:
Expected: iterable over [<2>, <1>, <4>, <3>, <7>] in any order
but: No item matches: <7> in [<1>, <2>, <3>, <4>]
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.that(PAssert.java:392)
at org.apache.beam.sdk.testing.PAssert.that(PAssert.java:384)
at org.apache.beam.sdk.testing.PAssertTest.testContainsInAnyOrderFalse(PAssertTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:319)
at org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:265)
at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:349)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:314)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:312)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:292)
at org.junit.runners.ParentRunner.run(ParentRunner.java:396)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:106)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
at org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:66)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
at sun.reflect.GeneratedMethodAccessor43.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:117)
at sun.reflect.GeneratedMethodAccessor42.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:155)
at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:137)
at org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:404)
at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.AssertionError:
Expected: iterable over [<2>, <1>, <4>, <3>, <7>] in any order
but: No item matches: <7> in [<1>, <2>, <3>, <4>]
at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
at org.junit.Assert.assertThat(Assert.java:966)
at org.junit.Assert.assertThat(Assert.java:931)
at org.apache.beam.sdk.testing.PAssert$AssertContainsInAnyOrder.apply(PAssert.java:1346)
at org.apache.beam.sdk.testing.PAssert$AssertContainsInAnyOrder.apply(PAssert.java:1325)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:993)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:973)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1274)
at org.apache.beam.sdk.testing.PAssert$GroupedValuesCheckerDoFn.processElement(PAssert.java:1241)
at org.apache.beam.sdk.testing.PAssert$GroupedValuesCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:275)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:240)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:78)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:148)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:50)
at org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction$$anon$1.flatMap(FlatMapFunction.scala:35)
at org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper.process(FunctionRunner.scala:84)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.process(FunctionRunner.scala:52)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen$$anonfun$1.apply(FunctionRunner.scala:56)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen$$anonfun$1.apply(FunctionRunner.scala:56)
at scala.collection.Iterator$$anon$12.nextCur(Iterator.scala:434)
at scala.collection.Iterator$$anon$12.hasNext(Iterator.scala:440)
at scala.collection.Iterator$class.isEmpty(Iterator.scala:330)
at scala.collection.AbstractIterator.isEmpty(Iterator.scala:1336)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:57)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.onTrigger$1(WindowRunner.scala:128)
at org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.trigger(WindowRunner.scala:152)
at org.apache.gearpump.streaming.task.TaskUtil$.trigger(TaskUtil.scala:41)
at org.apache.gearpump.streaming.dsl.task.GroupByTask$$anon$1.accept(GroupByTask.scala:70)
at org.apache.gearpump.streaming.dsl.task.GroupByTask$$anon$1.accept(GroupByTask.scala:68)
at java.lang.Iterable.forEach(Iterable.java:75)
at org.apache.gearpump.streaming.dsl.task.GroupByTask.onWatermarkProgress(GroupByTask.scala:68)
at org.apache.gearpump.streaming.task.TaskWrapper.onWatermarkProgress(TaskWrapper.scala:140)
at org.apache.gearpump.streaming.task.TaskActor.org$apache$gearpump$streaming$task$TaskActor$$onUpstreamMinClock(TaskActor.scala:330)
at org.apache.gearpump.streaming.task.TaskActor$$anonfun$handleMessages$1.applyOrElse(TaskActor.scala:193)
at akka.actor.Actor$class.aroundReceive(Actor.scala:496)
at org.apache.gearpump.streaming.task.TaskActor.aroundReceive(TaskActor.scala:47)
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)
Dec 26, 2018 3:26:45 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Create.Values/Read(CreateSource).out:
Expected: iterable over [<2>, <1>, <4>, <3>, <7>] in any order
but: No item matches: <7> in [<1>, <2>, <3>, <4>]
Dec 26, 2018 3:26:45 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(4,0) fails too many times to recover
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1545838005099
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$killAppMaster
INFO: Shutdown AppMaster at akka://master/user/Worker0, appId: 1, executorId: -1
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Shutdown executor app1-executor-1(akka://master/user/Worker0/$c) due to: AppMaster 1 shutdown requested by master...
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.testing.CombineFnTesterTest STANDARD_ERROR
Dec 26, 2018 3:26:45 PM org.apache.gearpump.util.ActorSystemBooter$Daemon$$anonfun$waitCommand$1 applyOrElse
INFO: System app1system0 Watched actor is terminated Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$b/$a#1186424886]
Dec 26, 2018 3:26:45 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Dec 26, 2018 3:26:45 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$terminationWatch$1 applyOrElse
INFO: AppMaster(akka://master/user/Worker0/$c/$a/appdaemon1/$c) is terminated, network down: false
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#557805509],WorkerId(0,1545838003865),Resource(999))...
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#557805509],WorkerId(0,1545838003865),Resource(1000))...
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Dec 26, 2018 3:26:45 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
org.apache.beam.sdk.values.PDoneTest > testEmptyTransform SKIPPED
org.apache.beam.sdk.values.PCollectionTupleTest > testComposePCollectionTuple STANDARD_ERROR
Dec 26, 2018 3:26:45 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1 applyOrElse
INFO: Slf4jLogger started
Dec 26, 2018 3:26:45 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$3 apply$mcV$sp
INFO: Starting remoting
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]
Uncaught error from thread [master-akka.actor.default-dispatcher-2] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
java.lang.OutOfMemoryError: unable to create new native thread
Uncaught error from thread [master-akka.remote.default-remote-dispatcher-5] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:717)
at scala.concurrent.forkjoin.ForkJoinPool.tryAddWorker(ForkJoinPool.java:1672)
at scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
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.ActorCell.start(ActorCell.scala:374)
at akka.actor.RepointableActorRef.point(RepointableActorRef.scala:107)
at akka.actor.ActorCell.handleSupervise(ActorCell.scala:625)
at akka.actor.ActorCell.supervise(ActorCell.scala:617)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:468)
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)
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)
at scala.concurrent.forkjoin.ForkJoinPool.deregisterWorker(ForkJoinPool.java:1795)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:117)
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
org.apache.beam.sdk.values.PCollectionTupleTest > testComposePCollectionTuple SKIPPED
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':',5,main]) completed. Took 1 mins 6.347 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> Process 'Gradle Test Executor 2' 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 2m 55s
37 actionable tasks: 37 executed
Publishing build scan...
https://gradle.com/s/7sar35tnte66y
Stopped 1 worker daemon(s).
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal :
beam_PostCommit_Java_ValidatesRunner_Gearpump #1740
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/1740/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump #1739
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/1739/display/redirect>
------------------------------------------
[...truncated 5.52 MB...]
INFO: Set DAG for TaskScheduler, count: 18
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.JarScheduler$JarSchedulerImpl$$anonfun$ready$1 applyOrElse
INFO: GetRequestDetails ResourceRequestDetail(null,[Lorg.apache.gearpump.cluster.scheduler.ResourceRequest;@20542ab3)
Dec 26, 2018 6:08:54 PM org.apache.gearpump.cluster.appmaster.ExecutorSystemScheduler$$anonfun$clientCommands$1 applyOrElse
INFO: starting executor systems (ExecutorSystemConfig(ExecutorSystemJvmConfig([Ljava.lang.String;@37dd0c70,[Ljava.lang.String;@4ba056b9,Some(null),jenkins,Config(SimpleConfigObject({"akka":{"actor":{"default-dispatcher":{"fork-join-executor":{"parallelism-factor":2,"parallelism-max":4,"parallelism-min":4},"throughput":10},"default-mailbox":{"mailbox-type":"akka.dispatch.SingleConsumerOnlyUnboundedMailbox"},"kryo":{"buffer-size":4096,"classes":[],"compression":"off","idstrategy":"incremental","implicit-registration-logging":true,"kryo-reference-map":true,"kryo-trace":false,"max-buffer-size":-1,"serializer-pool-size":16,"type":"graph","use-manifests":false},"provider":"akka.cluster.ClusterActorRefProvider","warn-about-java-serializer-usage":false},"daemonic":"on","extensions":["org.apache.gearpump.transport.Express$","org.apache.gearpump.metrics.Metrics$"],"http":{"client":{"parsing":{"max-content-length":"2048m"}},"server":{"parsing":{"illegal-header-warnings":"off","max-content-length":"2048m"},"remote-address-header":"on"},"session":{"cookie":{"http-only":true,"name":"gearpump_token","path":"/","secure":false},"encrypt-data":true,"max-age":604800,"server-secret":"Please change this to a value only you know! At least 64 chars!!!"}},"io":{"tcp":{"windows-connection-abort-workaround-enabled":"off"}},"log-dead-letters":"off","log-dead-letters-during-shutdown":"off","loggers":["akka.event.slf4j.Slf4jLogger"],"logging-filter":"akka.event.slf4j.Slf4jLoggingFilter","loglevel":"INFO","remote":{"default-remote-dispatcher":{"executor":"fork-join-executor","throughput":5,"type":"Dispatcher"},"enabled-transports":["akka.remote.netty.tcp"],"log-remote-lifecycle-events":"off","netty":{"tcp":{"hostname":"127.0.0.1","maximum-frame-size":"2048000b","port":45847,"receive-buffer-size":"4096000b","send-buffer-size":"4096000b"}},"use-dispatcher":"akka.remote.default-remote-dispatcher"},"scheduler":{"tick-duration":1},"test":{"single-expect-default":"10s"}},"beamTestPipelineOptions":"[\"--runner=TestGearpumpRunner\",\"--streaming=true\"]","gearpump":{"application":{"executor-num":1,"total-retries":0},"appmaster":{"extraClasspath":"","vmargs":""},"cgroup":{"cpu-core-limit-per-executor":1,"root":"gearpump"},"cluster":{"masters":["127.0.0.1:45847"]},"executor":{"extraClasspath":"","vmargs":""},"home":"","hostname":"127.0.0.1","jarstore":{"rootpath":"jarstore/"},"log":{"application":{"dir":"logs"},"daemon":{"dir":"logs"}},"master-resource-manager-container-id":"","masterclient":{"timeout":90},"metrics":{"akka":{"max-limit-on-query":1000,"metrics-aggregator-class":{"org.apache.gearpump.streaming.metrics.ProcessorAggregator":"","org.apache.gearpump.streaming.metrics.TaskFilterAggregator":""}},"enabled":true,"graphite":{"host":"127.0.0.1","port":2003},"report-interval-ms":3000,"reporter":"akka","retainHistoryData":{"hours":72,"intervalMs":3600000},"retainRecentData":{"intervalMs":15000,"seconds":300},"sample-rate":1},"netty":{"base-sleep-ms":100,"buffer-size":5242880,"dispatcher":"gearpump.shared-thread-pool-dispatcher","flush-check-interval":5,"max-retries":30,"max-sleep-ms":1000,"message-batch-size":262144},"remote-debug-executor-jvm":false,"resource-allocation-timeout-seconds":120,"scheduling":{"scheduler-class":"org.apache.gearpump.cluster.scheduler.PriorityScheduler"},"serialization-framework":"org.apache.gearpump.serializer.FastKryoSerializationFramework","serializer":{"pool":"org.apache.gearpump.serializer.FastKryoSerializerPool"},"serializers":{"[B":"","[C":"","[D":"","[F":"","[I":"","[J":"","[Ljava.lang.String;":"","[S":"","[Z":"","akka.actor.LocalActorRef":"","scala.Array":"","scala.Tuple1":"","scala.Tuple2":"","scala.Tuple3":"","scala.Tuple4":"","scala.Tuple5":"","scala.Tuple6":"","scala.collection.immutable.$colon$colon":"","scala.collection.immutable.List":"","scala.collection.immutable.Vector":""},"services":{"config-render-option-concise":true,"host":"127.0.0.1","http":8090,"supervisor-actor-path":""},"shared-thread-pool-dispatcher":{"fork-join-executor":{"parallelism-factor":2,"parallelism-max":8,"parallelism-min":2},"mailbox-type":"akka.dispatch.SingleConsumerOnlyUnboundedMailbox","throughput":100},"single-thread-dispatcher":{"type":"PinnedDispatcher"},"start-executor-system-timeout-ms":120000,"streaming":{"ack-once-every-message-count":100,"max-pending-message-count-per-connection":1000,"register-task-timeout-ms":120000},"task-dispatcher":"gearpump.shared-thread-pool-dispatcher","transport":{"serializer":"org.apache.gearpump.streaming.task.StreamingTransportSerializer"},"ui-default-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"core-pool-size-factor":2,"core-pool-size-max":32,"core-pool-size-min":2},"throughput":1,"type":"Dispatcher"},"verbose-gc":false,"worker":{"executor-process-launcher":"org.apache.gearpump.cluster.worker.DefaultExecutorProcessLauncher","executor-share-same-jvm-as-worker":true,"slots":1000},"worker-resource-manager-container-id":"","yarn":{"applicationmaster":{"command":"$JAVA_HOME/bin/java -Xmx512m","memory":"512","queue":"default","vcores":"1"},"client":{"package-path":"/usr/lib/gearpump/gearpump.zip"},"master":{"command":"$JAVA_HOME/bin/java -Xmx512m","memory":"512","vcores":"1"},"services":{"enabled":true},"worker":{"command":"$JAVA_HOME/bin/java -Xmx512m","containers":"1","memory":"4096","vcores":"1"}}},"org":{"gradle":{"native":"false","test":{"worker":"1"}}}})))), Resources(ResourceRequest(Resource(18),WorkerId(-1,0),NORMAL,ANY,1)))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.cluster.scheduler.PriorityScheduler$$anonfun$resourceRequestHandler$1 applyOrElse
INFO: Request resource: appId: 1, slots: 18, relaxation: ANY, executor number: 1
Dec 26, 2018 6:08:54 PM org.apache.gearpump.cluster.appmaster.ExecutorSystemLauncher$$anonfun$waitForLaunchCommand$1 applyOrElse
INFO: Launching Executor ...appId: 1, executorSystemId: 0, slots: 18 on worker WorkerInfo(WorkerId(0,1545847729294),Actor[akka://master/user/Worker0#1932040619])
Dec 26, 2018 6:08:54 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: LaunchExecutor(1,0,Resource(18),ExecutorJVMConfig([Ljava.lang.String;@37dd0c70,[Ljava.lang.String;@4ba056b9,org.apache.gearpump.util.ActorSystemBooter,[Ljava.lang.String;@12293d8b,Some(null),jenkins,Config(SimpleConfigObject({"akka":{"actor":{"default-dispatcher":{"fork-join-executor":{"parallelism-factor":2,"parallelism-max":4,"parallelism-min":4},"throughput":10},"default-mailbox":{"mailbox-type":"akka.dispatch.SingleConsumerOnlyUnboundedMailbox"},"kryo":{"buffer-size":4096,"classes":[],"compression":"off","idstrategy":"incremental","implicit-registration-logging":true,"kryo-reference-map":true,"kryo-trace":false,"max-buffer-size":-1,"serializer-pool-size":16,"type":"graph","use-manifests":false},"provider":"akka.cluster.ClusterActorRefProvider","warn-about-java-serializer-usage":false},"daemonic":"on","extensions":["org.apache.gearpump.transport.Express$","org.apache.gearpump.metrics.Metrics$"],"http":{"client":{"parsing":{"max-content-length":"2048m"}},"server":{"parsing":{"illegal-header-warnings":"off","max-content-length":"2048m"},"remote-address-header":"on"},"session":{"cookie":{"http-only":true,"name":"gearpump_token","path":"/","secure":false},"encrypt-data":true,"max-age":604800,"server-secret":"Please change this to a value only you know! At least 64 chars!!!"}},"io":{"tcp":{"windows-connection-abort-workaround-enabled":"off"}},"log-dead-letters":"off","log-dead-letters-during-shutdown":"off","loggers":["akka.event.slf4j.Slf4jLogger"],"logging-filter":"akka.event.slf4j.Slf4jLoggingFilter","loglevel":"INFO","remote":{"default-remote-dispatcher":{"executor":"fork-join-executor","throughput":5,"type":"Dispatcher"},"enabled-transports":["akka.remote.netty.tcp"],"log-remote-lifecycle-events":"off","netty":{"tcp":{"hostname":"127.0.0.1","maximum-frame-size":"2048000b","port":45847,"receive-buffer-size":"4096000b","send-buffer-size":"4096000b"}},"use-dispatcher":"akka.remote.default-remote-dispatcher"},"scheduler":{"tick-duration":1},"test":{"single-expect-default":"10s"}},"beamTestPipelineOptions":"[\"--runner=TestGearpumpRunner\",\"--streaming=true\"]","gearpump":{"application":{"executor-num":1,"total-retries":0},"appmaster":{"extraClasspath":"","vmargs":""},"cgroup":{"cpu-core-limit-per-executor":1,"root":"gearpump"},"cluster":{"masters":["127.0.0.1:45847"]},"executor":{"extraClasspath":"","vmargs":""},"home":"","hostname":"127.0.0.1","jarstore":{"rootpath":"jarstore/"},"log":{"application":{"dir":"logs"},"daemon":{"dir":"logs"}},"master-resource-manager-container-id":"","masterclient":{"timeout":90},"metrics":{"akka":{"max-limit-on-query":1000,"metrics-aggregator-class":{"org.apache.gearpump.streaming.metrics.ProcessorAggregator":"","org.apache.gearpump.streaming.metrics.TaskFilterAggregator":""}},"enabled":true,"graphite":{"host":"127.0.0.1","port":2003},"report-interval-ms":3000,"reporter":"akka","retainHistoryData":{"hours":72,"intervalMs":3600000},"retainRecentData":{"intervalMs":15000,"seconds":300},"sample-rate":1},"netty":{"base-sleep-ms":100,"buffer-size":5242880,"dispatcher":"gearpump.shared-thread-pool-dispatcher","flush-check-interval":5,"max-retries":30,"max-sleep-ms":1000,"message-batch-size":262144},"remote-debug-executor-jvm":false,"resource-allocation-timeout-seconds":120,"scheduling":{"scheduler-class":"org.apache.gearpump.cluster.scheduler.PriorityScheduler"},"serialization-framework":"org.apache.gearpump.serializer.FastKryoSerializationFramework","serializer":{"pool":"org.apache.gearpump.serializer.FastKryoSerializerPool"},"serializers":{"[B":"","[C":"","[D":"","[F":"","[I":"","[J":"","[Ljava.lang.String;":"","[S":"","[Z":"","akka.actor.LocalActorRef":"","scala.Array":"","scala.Tuple1":"","scala.Tuple2":"","scala.Tuple3":"","scala.Tuple4":"","scala.Tuple5":"","scala.Tuple6":"","scala.collection.immutable.$colon$colon":"","scala.collection.immutable.List":"","scala.collection.immutable.Vector":""},"services":{"config-render-option-concise":true,"host":"127.0.0.1","http":8090,"supervisor-actor-path":""},"shared-thread-pool-dispatcher":{"fork-join-executor":{"parallelism-factor":2,"parallelism-max":8,"parallelism-min":2},"mailbox-type":"akka.dispatch.SingleConsumerOnlyUnboundedMailbox","throughput":100},"single-thread-dispatcher":{"type":"PinnedDispatcher"},"start-executor-system-timeout-ms":120000,"streaming":{"ack-once-every-message-count":100,"max-pending-message-count-per-connection":1000,"register-task-timeout-ms":120000},"task-dispatcher":"gearpump.shared-thread-pool-dispatcher","transport":{"serializer":"org.apache.gearpump.streaming.task.StreamingTransportSerializer"},"ui-default-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"core-pool-size-factor":2,"core-pool-size-max":32,"core-pool-size-min":2},"throughput":1,"type":"Dispatcher"},"verbose-gc":false,"worker":{"executor-process-launcher":"org.apache.gearpump.cluster.worker.DefaultExecutorProcessLauncher","executor-share-same-jvm-as-worker":true,"slots":1000},"worker-resource-manager-container-id":"","yarn":{"applicationmaster":{"command":"$JAVA_HOME/bin/java -Xmx512m","memory":"512","queue":"default","vcores":"1"},"client":{"package-path":"/usr/lib/gearpump/gearpump.zip"},"master":{"command":"$JAVA_HOME/bin/java -Xmx512m","memory":"512","vcores":"1"},"services":{"enabled":true},"worker":{"command":"$JAVA_HOME/bin/java -Xmx512m","containers":"1","memory":"4096","vcores":"1"}}},"org":{"gradle":{"native":"false","test":{"worker":"1"}}}}))))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#1932040619],WorkerId(0,1545847729294),Resource(981))...
Dec 26, 2018 6:08:54 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Dec 26, 2018 6:08:54 PM org.apache.gearpump.util.ActorSystemBooter$Daemon <init>
INFO: RegisterActorSystem to akka.tcp://master@127.0.0.1:45847/user/Worker0/$c/$a/appdaemon1/$b/$a/$b, current user: not_defined
Dec 26, 2018 6:08:54 PM org.apache.gearpump.cluster.appmaster.ExecutorSystemLauncher$$anonfun$waitForActorSystemToStart$1 applyOrElse
INFO: Received RegisterActorSystem akka.tcp://master@127.0.0.1:45847 for session Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors#1744663439]
Dec 26, 2018 6:08:54 PM org.apache.gearpump.cluster.appmaster.ExecutorSystemScheduler$$anonfun$executorSystemMessageHandler$1 applyOrElse
INFO: LaunchExecutorSystemSuccess, send back to Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors#1744663439]
Dec 26, 2018 6:08:54 PM org.apache.gearpump.util.ActorSystemBooter$Daemon$$anonfun$waitCommand$1 applyOrElse
INFO: ActorSystem app1system0 Binding life cycle with actor: Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$b/$a#1144319748]
Dec 26, 2018 6:08:54 PM org.apache.gearpump.util.ActorSystemBooter$Daemon$$anonfun$waitCommand$1 applyOrElse
INFO: ActorSystem app1system0 Binding life cycle with actor: Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors/0#-1703255754]
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.executor.Executor <init>
INFO: Executor 0 has been started, start to register itself...
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.executor.Executor <init>
INFO: Executor actor path: akka.tcp://master@127.0.0.1:45847/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors/0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: executor 0 has been launched
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.JarScheduler$JarSchedulerImpl$$anonfun$ready$1 applyOrElse
INFO: ScheduleTask TaskId(15,0);TaskId(4,0);TaskId(8,0);TaskId(11,0);TaskId(16,0);TaskId(3,0);TaskId(7,0);TaskId(12,0);TaskId(17,0);TaskId(2,0);TaskId(13,0);TaskId(9,0);TaskId(6,0);TaskId(1,0);TaskId(14,0);TaskId(10,0);TaskId(5,0);TaskId(0,0)
Dec 26, 2018 6:08:54 PM org.apache.gearpump.metrics.MetricsReporterService getReporter
INFO: Metrics reporter is enabled, using akka reporter
Dec 26, 2018 6:08:54 PM org.apache.gearpump.metrics.AkkaReporter <init>
INFO: Start Metrics AkkaReporter
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1$$anonfun$applyOrElse$5 apply
INFO: Executor ExecutorStarted(0,Resource(18),WorkerId(0,1545847729294),Some(null)) has been started, start to schedule tasks: TaskId(15,0),TaskId(4,0),TaskId(8,0),TaskId(11,0),TaskId(16,0),TaskId(3,0),TaskId(7,0),TaskId(12,0),TaskId(17,0),TaskId(2,0),TaskId(13,0),TaskId(9,0),TaskId(6,0),TaskId(1,0),TaskId(14,0),TaskId(10,0),TaskId(5,0),TaskId(0,0)
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 0, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 5, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 10, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(0,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 14, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 1, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(5,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 6, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(10,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 9, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(14,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 13, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(1,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.executor.Executor$$anonfun$applicationReady$1 applyOrElse
INFO: received LaunchTasks(List(TaskId(0,0)),0,ProcessorDescription(0,org.apache.gearpump.streaming.source.DataSourceTask,1,source.globalWindows,org.apache.gearpump.cluster.UserConfig@1616bb16,LifeTime(-9223372036854775808,9223372036854775807),null),List(Subscriber(4,PartitionerDescription(org.apache.gearpump.streaming.partitioner.PartitionerObject@5bc5a8bd),1,LifeTime(-9223372036854775808,9223372036854775807)), Subscriber(5,PartitionerDescription(org.apache.gearpump.streaming.partitioner.PartitionerObject@37d1e1f9),1,LifeTime(-9223372036854775808,9223372036854775807)))), Executor transit to dag version: 0 from current version -1
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(5,0)) for app: 1
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(6,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 2, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(9,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 17, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(13,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 12, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(2,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 7, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(17,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 3, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(12,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 16, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(7,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(3,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 11, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(16,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(10,0)) for app: 1
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(11,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 8, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express registerLocalActor
INFO: RegisterLocalActor: 21474836480, actor: processor_5_task_0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(0,0)) for app: 1
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(8,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express init$lzycompute
INFO: Start Express init ...master
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express registerLocalActor
INFO: RegisterLocalActor: 42949672960, actor: processor_10_task_0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 4, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express registerLocalActor
INFO: RegisterLocalActor: 0, actor: processor_0_task_0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(4,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(14,0)) for app: 1
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 15, dagVersion: 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(15,0))
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express init$lzycompute
INFO: Start Express init ...master
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(1,0)) for app: 1
Dec 26, 2018 6:08:54 PM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(6,0)) for app: 1
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express init$lzycompute
INFO: Start Express init ...master
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express registerLocalActor
INFO: RegisterLocalActor: 4294967296, actor: processor_1_task_0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express init$lzycompute
INFO: Start Express init ...master
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express registerLocalActor
INFO: RegisterLocalActor: 25769803776, actor: processor_6_task_0
Dec 26, 2018 6:08:54 PM org.apache.gearpump.transport.Express init$lzycompute
INFO: Start Express init ...master
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-2] 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]
Uncaught error from thread [master-akka.actor.default-dispatcher-5] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
Uncaught error from thread [master-gearpump.shared-thread-pool-dispatcher-20] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
Uncaught error from thread [master-gearpump.shared-thread-pool-dispatcher-18] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
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)
at scala.concurrent.forkjoin.ForkJoinPool.deregisterWorker(ForkJoinPool.java:1795)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:117)
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)
at scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
at scala.concurrent.forkjoin.ForkJoinPool.fullExternalPush(ForkJoinPool.java:1905)
at scala.concurrent.forkjoin.ForkJoinPool.externalPush(ForkJoinPool.java:1834)
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)
org.apache.beam.sdk.transforms.CombineTest$BasicTests > testSimpleCombine SKIPPED
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 7 mins 30.952 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 8m 49s
37 actionable tasks: 33 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/t6lrhl5qazmf6
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump #1738
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/1738/display/redirect?page=changes>
Changes:
[apilloud] Upgrade to Calcite 1.18
------------------------------------------
[...truncated 1.27 MB...]
but: No item matches: <7> in [<1>, <2>, <3>, <4>]
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.that(PAssert.java:392)
at org.apache.beam.sdk.testing.PAssert.that(PAssert.java:384)
at org.apache.beam.sdk.testing.PAssertTest.testContainsInAnyOrderFalse(PAssertTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:319)
at org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:265)
at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:349)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:314)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:312)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:292)
at org.junit.runners.ParentRunner.run(ParentRunner.java:396)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:106)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
at org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:66)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
at sun.reflect.GeneratedMethodAccessor41.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:117)
at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:155)
at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:137)
at org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:404)
at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.AssertionError:
Expected: iterable over [<2>, <1>, <4>, <3>, <7>] in any order
but: No item matches: <7> in [<1>, <2>, <3>, <4>]
at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
at org.junit.Assert.assertThat(Assert.java:966)
at org.junit.Assert.assertThat(Assert.java:931)
at org.apache.beam.sdk.testing.PAssert$AssertContainsInAnyOrder.apply(PAssert.java:1346)
at org.apache.beam.sdk.testing.PAssert$AssertContainsInAnyOrder.apply(PAssert.java:1325)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:993)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:973)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1274)
at org.apache.beam.sdk.testing.PAssert$GroupedValuesCheckerDoFn.processElement(PAssert.java:1241)
at org.apache.beam.sdk.testing.PAssert$GroupedValuesCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:275)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:240)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:78)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:148)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:50)
at org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction$$anon$1.flatMap(FlatMapFunction.scala:35)
at org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper.process(FunctionRunner.scala:84)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.process(FunctionRunner.scala:52)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen$$anonfun$1.apply(FunctionRunner.scala:56)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen$$anonfun$1.apply(FunctionRunner.scala:56)
at scala.collection.Iterator$$anon$12.nextCur(Iterator.scala:434)
at scala.collection.Iterator$$anon$12.hasNext(Iterator.scala:440)
at scala.collection.Iterator$class.isEmpty(Iterator.scala:330)
at scala.collection.AbstractIterator.isEmpty(Iterator.scala:1336)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:57)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.plan.functions.AndThen.finish(FunctionRunner.scala:58)
at org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.onTrigger$1(WindowRunner.scala:128)
at org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.trigger(WindowRunner.scala:152)
at org.apache.gearpump.streaming.task.TaskUtil$.trigger(TaskUtil.scala:41)
at org.apache.gearpump.streaming.dsl.task.GroupByTask$$anon$1.accept(GroupByTask.scala:70)
at org.apache.gearpump.streaming.dsl.task.GroupByTask$$anon$1.accept(GroupByTask.scala:68)
at java.lang.Iterable.forEach(Iterable.java:75)
at org.apache.gearpump.streaming.dsl.task.GroupByTask.onWatermarkProgress(GroupByTask.scala:68)
at org.apache.gearpump.streaming.task.TaskWrapper.onWatermarkProgress(TaskWrapper.scala:140)
at org.apache.gearpump.streaming.task.TaskActor.org$apache$gearpump$streaming$task$TaskActor$$onUpstreamMinClock(TaskActor.scala:330)
at org.apache.gearpump.streaming.task.TaskActor$$anonfun$handleMessages$1.applyOrElse(TaskActor.scala:193)
at akka.actor.Actor$class.aroundReceive(Actor.scala:496)
at org.apache.gearpump.streaming.task.TaskActor.aroundReceive(TaskActor.scala:47)
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)
Dec 26, 2018 5:16:07 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Create.Values/Read(CreateSource).out:
Expected: iterable over [<2>, <1>, <4>, <3>, <7>] in any order
but: No item matches: <7> in [<1>, <2>, <3>, <4>]
Dec 26, 2018 5:16:07 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(4,0) fails too many times to recover
Dec 26, 2018 5:16:07 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1545844567922
Dec 26, 2018 5:16:07 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$killAppMaster
INFO: Shutdown AppMaster at akka://master/user/Worker0, appId: 1, executorId: -1
Dec 26, 2018 5:16:07 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Shutdown executor app1-executor-1(akka://master/user/Worker0/$c) due to: AppMaster 1 shutdown requested by master...
Dec 26, 2018 5:16:07 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Dec 26, 2018 5:16:07 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
Gradle Test Executor 2 STANDARD_ERROR
Dec 26, 2018 5:16:07 PM org.apache.gearpump.util.ActorSystemBooter$Daemon$$anonfun$waitCommand$1 applyOrElse
INFO: System app1system0 Watched actor is terminated Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$b/$a#-248681559]
org.apache.beam.sdk.testing.CombineFnTesterTest STANDARD_ERROR
Dec 26, 2018 5:16:07 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Dec 26, 2018 5:16:07 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Dec 26, 2018 5:16:07 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$terminationWatch$1 applyOrElse
INFO: AppMaster(akka://master/user/Worker0/$c/$a/appdaemon1/$c) is terminated, network down: false
Dec 26, 2018 5:16:07 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Dec 26, 2018 5:16:07 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-1827889839],WorkerId(0,1545844566890),Resource(995))...
Dec 26, 2018 5:16:07 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
org.apache.beam.sdk.testing.CoderPropertiesTest STANDARD_ERROR
Uncaught error from thread [master-akka.actor.default-dispatcher-5] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
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]
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 scala.concurrent.impl.ExecutionContextImpl$$anon$1.execute(ExecutionContextImpl.scala:136)
at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40)
at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:248)
at scala.concurrent.Promise$class.complete(Promise.scala:55)
at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:153)
at scala.concurrent.Promise$class.success(Promise.scala:86)
at scala.concurrent.impl.Promise$DefaultPromise.success(Promise.scala:153)
at org.apache.gearpump.cluster.worker.Worker$InJvmExecutor.postStop(Worker.scala:575)
at akka.actor.Actor$class.aroundPostStop(Actor.scala:509)
at org.apache.gearpump.util.ActorSystemBooter$Daemon.aroundPostStop(ActorSystemBooter.scala:99)
at akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$finishTerminate(FaultHandling.scala:210)
at akka.actor.dungeon.FaultHandling$class.handleChildTerminated(FaultHandling.scala:293)
at akka.actor.ActorCell.handleChildTerminated(ActorCell.scala:374)
at akka.actor.dungeon.DeathWatch$class.watchedActorTerminated(DeathWatch.scala:63)
at akka.actor.ActorCell.watchedActorTerminated(ActorCell.scala:374)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:460)
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)
org.apache.beam.sdk.testing.ValueInSingleWindowCoderTest STANDARD_ERROR
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 scala.concurrent.impl.ExecutionContextImpl$$anon$1.execute(ExecutionContextImpl.scala:136)
at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40)
at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:248)
at scala.concurrent.Promise$class.complete(Promise.scala:55)
at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:153)
at scala.concurrent.Promise$class.success(Promise.scala:86)
at scala.concurrent.impl.Promise$DefaultPromise.success(Promise.scala:153)
at org.apache.gearpump.cluster.worker.Worker$InJvmExecutor.postStop(Worker.scala:575)
at akka.actor.Actor$class.aroundPostStop(Actor.scala:509)
at org.apache.gearpump.util.ActorSystemBooter$Daemon.aroundPostStop(ActorSystemBooter.scala:99)
at akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$finishTerminate(FaultHandling.scala:210)
at akka.actor.dungeon.FaultHandling$class.terminate(FaultHandling.scala:172)
at akka.actor.ActorCell.terminate(ActorCell.scala:374)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:467)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:483)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:260)
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)
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 1 mins 6.042 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> Process 'Gradle Test Executor 2' 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 2m 58s
37 actionable tasks: 37 executed
Publishing build scan...
https://gradle.com/s/qq5yhblt2jxxw
Stopped 1 worker daemon(s).
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org