You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/06/21 22:31:38 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #16
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/16/display/redirect?page=changes>
Changes:
[lcwik] Revert "Revert #5689 to fix build"
[kenn] Migrate build_rules.gradle to buildSrc plugin
------------------------------------------
[...truncated 12.35 MB...]
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.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.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:109)
at sun.reflect.GeneratedMethodAccessor39.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 21, 2018 10:31:34 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(66,0) fails too many times to recover
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529620294046
Jun 21, 2018 10:31:34 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
Jun 21, 2018 10:31:34 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...
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 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#1052515899]
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#908934756],WorkerId(0,1529619973687),Resource(999))...
Gradle Test Executor 1 STANDARD_ERROR
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
org.apache.beam.sdk.runners.TransformHierarchyTest STANDARD_ERROR
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:31:34 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
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#908934756],WorkerId(0,1529619973687),Resource(1000))...
Jun 21, 2018 10:31:34 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.26 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.187 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 22 mins 52.967 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 24m 13s
31 actionable tasks: 27 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/se77lekywni5m
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Jenkins build is back to normal :
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #29
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/29/display/redirect?page=changes>
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #28
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/28/display/redirect?page=changes>
Changes:
[Pablo] Enabling gradle build to receive extra buildscript repositories
------------------------------------------
[...truncated 12.40 MB...]
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:71)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor38.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:109)
at sun.reflect.GeneratedMethodAccessor37.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(64,0) fails too many times to recover
Jun 22, 2018 6:25:59 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529691959627
Jun 22, 2018 6:25:59 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
Jun 22, 2018 6:25:59 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...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:71)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 22, 2018 6:25:59 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#-1765025815]
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-9373094],WorkerId(0,1529691782581),Resource(999))...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
org.apache.beam.sdk.runners.TransformHierarchyTest STANDARD_ERROR
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:25:59 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
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-9373094],WorkerId(0,1529691782581),Resource(1000))...
Jun 22, 2018 6:25:59 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.228 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.231 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 18 mins 39.572 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 19m 35s
31 actionable tasks: 27 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/jjnqvbclyqxqc
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user klk@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #27
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/27/display/redirect>
------------------------------------------
[...truncated 12.26 MB...]
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:69)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor39.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:109)
at sun.reflect.GeneratedMethodAccessor38.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(65,0) fails too many times to recover
Jun 22, 2018 5:23:10 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529688190515
Jun 22, 2018 5:23:10 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
Jun 22, 2018 5:23:10 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...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:69)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 22, 2018 5:23:10 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#-721991588]
org.apache.beam.sdk.runners.TransformHierarchyTest STANDARD_ERROR
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-611813321],WorkerId(0,1529688011534),Resource(999))...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 5:23:10 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
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-611813321],WorkerId(0,1529688011534),Resource(1000))...
Jun 22, 2018 5:23:10 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.183 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.186 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 18 mins 46.214 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 20m 6s
31 actionable tasks: 31 executed
Publishing build scan...
https://gradle.com/s/673hsdoafio44
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user klk@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #26
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/26/display/redirect?page=changes>
Changes:
[iemejia] Fix maven compile for the 8th time (yay!)
------------------------------------------
[...truncated 12.43 MB...]
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:71)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor38.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:109)
at sun.reflect.GeneratedMethodAccessor37.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(64,0) fails too many times to recover
Jun 22, 2018 2:38:56 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529678336854
Jun 22, 2018 2:38:56 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
Jun 22, 2018 2:38:56 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...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:71)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 22, 2018 2:38:56 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#-1078342441]
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 22, 2018 2:38:56 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
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-918224167],WorkerId(0,1529678179423),Resource(999))...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-918224167],WorkerId(0,1529678179423),Resource(1000))...
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 22, 2018 2:38:56 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.192 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.213 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 17 mins 47.585 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 18m 45s
31 actionable tasks: 27 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/ffoqedafovzzy
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user klk@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #25
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/25/display/redirect?page=changes>
Changes:
[klk] Fix errors in BeamModulePlugin perf test section
------------------------------------------
[...truncated 12.29 MB...]
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:69)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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:109)
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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(65,0) fails too many times to recover
Jun 22, 2018 1:20:13 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529673613704
Jun 22, 2018 1:20:13 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
Jun 22, 2018 1:20:13 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...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:69)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 22, 2018 1:20:13 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#478984478]
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#602358220],WorkerId(0,1529673442397),Resource(999))...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 1:20:13 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
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#602358220],WorkerId(0,1529673442397),Resource(1000))...
Jun 22, 2018 1:20:13 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.184 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.169 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Daemon worker,5,main]) completed. Took 17 mins 58.452 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 19m 18s
31 actionable tasks: 31 executed
Publishing build scan...
https://gradle.com/s/grdx6xllgvne2
Stopped 1 worker daemon(s).
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user klk@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #24
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/24/display/redirect?page=changes>
Changes:
[iemejia] Fix errorprone warnings on extensions/google-cloud-platform-core module
[iemejia] Enable errorprone globally
------------------------------------------
[...truncated 12.34 MB...]
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:71)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor37.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:109)
at sun.reflect.GeneratedMethodAccessor36.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(64,0) fails too many times to recover
Jun 22, 2018 12:43:38 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529671418930
Jun 22, 2018 12:43:38 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
Jun 22, 2018 12:43:38 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...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:71)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
Gradle Test Executor 1 STANDARD_ERROR
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 22, 2018 12:43:38 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#-2101353066]
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-2129988933],WorkerId(0,1529671209613),Resource(999))...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:43:38 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
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-2129988933],WorkerId(0,1529671209613),Resource(1000))...
Jun 22, 2018 12:43:38 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.201 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.173 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 18 mins 53.341 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 20m 4s
31 actionable tasks: 31 executed
Publishing build scan...
https://gradle.com/s/vowkbpz26iuhu
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #23
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/23/display/redirect>
------------------------------------------
[...truncated 12.38 MB...]
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:71)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor38.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:109)
at sun.reflect.GeneratedMethodAccessor37.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 22, 2018 12:23:15 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(64,0) fails too many times to recover
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529670195877
Jun 22, 2018 12:23:15 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
Jun 22, 2018 12:23:15 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...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Max/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:71)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 22, 2018 12:23:15 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#-1903177578]
org.apache.beam.sdk.runners.TransformHierarchyTest STANDARD_ERROR
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#319776015],WorkerId(0,1529670021666),Resource(999))...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 12:23:15 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
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#319776015],WorkerId(0,1529670021666),Resource(1000))...
Jun 22, 2018 12:23:15 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.192 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.187 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 14,5,main]) completed. Took 18 mins 31.154 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 19m 29s
31 actionable tasks: 27 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/tzzot3p4sikji
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #22
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/22/display/redirect>
------------------------------------------
[...truncated 12.34 MB...]
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:78)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor37.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:109)
at sun.reflect.GeneratedMethodAccessor36.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(66,0) fails too many times to recover
Jun 22, 2018 6:33:44 AM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529649224917
Jun 22, 2018 6:33:44 AM 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
Jun 22, 2018 6:33:44 AM 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...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 22, 2018 6:33:44 AM 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#1508208218]
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 22, 2018 6:33:44 AM 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
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#1239058780],WorkerId(0,1529649021921),Resource(999))...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#1239058780],WorkerId(0,1529649021921),Resource(1000))...
Jun 22, 2018 6:33:44 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.24 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.178 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 8,5,main]) completed. Took 19 mins 40.078 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 20m 57s
31 actionable tasks: 31 executed
Publishing build scan...
https://gradle.com/s/ze2vlhknvzbb2
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #21
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/21/display/redirect?page=changes>
Changes:
[robertwb] [BEAM-4150] Extract IO coders from the RemoteGrpcPort.
[robertwb] Add back old code path for dataflow.
------------------------------------------
[...truncated 12.35 MB...]
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor38.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:109)
at sun.reflect.GeneratedMethodAccessor37.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(66,0) fails too many times to recover
Jun 22, 2018 6:05:04 AM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529647504044
Jun 22, 2018 6:05:04 AM 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
Jun 22, 2018 6:05:04 AM 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...
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
Gradle Test Executor 1 STANDARD_ERROR
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM 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#-1946174396]
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 22, 2018 6:05:04 AM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 22, 2018 6:05:04 AM 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
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-668775997],WorkerId(0,1529647318639),Resource(999))...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-668775997],WorkerId(0,1529647318639),Resource(1000))...
Jun 22, 2018 6:05:04 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.188 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.136 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 8,5,main]) completed. Took 18 mins 4.688 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 18m 58s
31 actionable tasks: 27 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/lnit3pckrvksa
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #20
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/20/display/redirect>
------------------------------------------
[...truncated 12.32 MB...]
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor38.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:109)
at sun.reflect.GeneratedMethodAccessor37.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(66,0) fails too many times to recover
Jun 21, 2018 11:53:36 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529625216073
Jun 21, 2018 11:53:36 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
Jun 21, 2018 11:53:36 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...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
Gradle Test Executor 1 STANDARD_ERROR
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 21, 2018 11:53:36 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#-1533293804]
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-1744333398],WorkerId(0,1529625049440),Resource(999))...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
org.apache.beam.sdk.runners.TransformHierarchyTest STANDARD_ERROR
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:53:36 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
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-1744333398],WorkerId(0,1529625049440),Resource(1000))...
Jun 21, 2018 11:53:36 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.182 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.164 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 18 mins 34.842 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 19m 31s
31 actionable tasks: 27 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/nkk5fsvvoovqy
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #19
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/19/display/redirect?page=changes>
Changes:
[kenn] Remove build_rules.gradle
------------------------------------------
[...truncated 12.39 MB...]
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:69)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor38.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:109)
at sun.reflect.GeneratedMethodAccessor37.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(65,0) fails too many times to recover
Jun 21, 2018 11:33:11 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529623991881
Jun 21, 2018 11:33:11 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
Jun 21, 2018 11:33:11 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...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:69)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 21, 2018 11:33:11 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#458346694]
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#645606194],WorkerId(0,1529623827699),Resource(999))...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
org.apache.beam.sdk.runners.TransformHierarchyTest STANDARD_ERROR
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:33:11 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
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#645606194],WorkerId(0,1529623827699),Resource(1000))...
Jun 21, 2018 11:33:11 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.206 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.214 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 14,5,main]) completed. Took 18 mins 2.168 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 19m 1s
31 actionable tasks: 27 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/l4klzhciqhyru
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #18
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/18/display/redirect?page=changes>
Changes:
[tgroh] Use the Current Users Container as the Environment
------------------------------------------
[...truncated 12.26 MB...]
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor38.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:109)
at sun.reflect.GeneratedMethodAccessor37.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(66,0) fails too many times to recover
Jun 21, 2018 11:14:00 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529622840015
Jun 21, 2018 11:14:00 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
Jun 21, 2018 11:14:00 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...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Count/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:64)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.io.CountingSourceTest STANDARD_ERROR
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 21, 2018 11:14:00 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#107258022]
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-131627402],WorkerId(0,1529622655490),Resource(999))...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 11:14:00 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
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-131627402],WorkerId(0,1529622655490),Resource(1000))...
Jun 21, 2018 11:14:00 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.232 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.185 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 19 mins 0.33 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 20m 19s
31 actionable tasks: 31 executed
Publishing build scan...
https://gradle.com/s/rmg3xvkgihxvc
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #17
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/17/display/redirect?page=changes>
Changes:
[amaliujia] support unbounded limit.
------------------------------------------
[...truncated 12.35 MB...]
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Caused by: java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:69)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
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:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:317)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
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.GeneratedMethodAccessor37.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:109)
at sun.reflect.GeneratedMethodAccessor36.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.NoClassDefFoundError: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1273)
at org.apache.beam.sdk.testing.PAssert$AssertIsEqualTo.apply(PAssert.java:1263)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:966)
at org.apache.beam.sdk.testing.PAssert$CheckRelationAgainstExpected.apply(PAssert.java:946)
at org.apache.beam.sdk.testing.PAssert.doChecks(PAssert.java:1250)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn.processElement(PAssert.java:1192)
at org.apache.beam.sdk.testing.PAssert$SideInputCheckerDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:146)
at org.apache.beam.runners.core.SimplePushbackSideInputDoFnRunner.processElementInReadyWindows(SimplePushbackSideInputDoFnRunner.java:87)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:149)
at org.apache.beam.runners.gearpump.translators.functions.DoFnFunction.flatMap(DoFnFunction.java:52)
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.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.TransformTask.onWatermarkProgress(TransformTask.scala:44)
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)
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$recover$1 applyOrElse
SEVERE: Task TaskId(65,0) fails too many times to recover
Jun 21, 2018 10:53:21 PM akka.event.slf4j.Slf4jLogger$$anonfun$receive$1$$anonfun$applyOrElse$2 apply$mcV$sp
WARNING: java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.master.AppManager org$apache$gearpump$cluster$master$AppManager$$onApplicationStatusChanged
INFO: Application 1 change to failed at 1529621601763
Jun 21, 2018 10:53:21 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
Jun 21, 2018 10:53:21 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...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.master.InMemoryKVService$$anonfun$kvService$1 applyOrElse
INFO: KV Group gearpump_kvservice_1 is deleted
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits FAILED
java.lang.AssertionError: Min/Flatten.PCollections.out: org/hamcrest/Matchers
at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:168)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:418)
at org.apache.beam.sdk.testing.PAssert.thatSingleton(PAssert.java:408)
at org.apache.beam.sdk.io.CountingSourceTest.addCountingAsserts(CountingSourceTest.java:69)
at org.apache.beam.sdk.io.CountingSourceTest.testBoundedSourceSplits(CountingSourceTest.java:118)
Caused by:
java.lang.NoClassDefFoundError: org/hamcrest/Matchers
org.apache.beam.sdk.io.CountingSourceTest STANDARD_ERROR
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.master.AppManager$$anonfun$workerMessage$1 applyOrElse
INFO: Shut down executor -1 for application 1 successfully
org.apache.beam.sdk.runners.TransformTreeTest STANDARD_ERROR
Jun 21, 2018 10:53:21 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#863091850]
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.worker.Worker$ExecutorWatcher$$anonfun$receive$1 applyOrElse
INFO: Executor exit normally with exit value 0
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor0)
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-1367255211],WorkerId(0,1529621441423),Resource(999))...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.streaming.source.DataSourceTask onStop
INFO: closing data source...
Jun 21, 2018 10:53:21 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
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$terminationWatch$1 applyOrElse
INFO: Executor is down Some(app1-executor-1)
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#-1367255211],WorkerId(0,1529621441423),Resource(1000))...
Jun 21, 2018 10:53:21 PM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
173 tests completed, 162 failed, 1 skipped
Finished generating test XML results (0.196 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.211 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming>
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 10,5,main]) completed. Took 18 mins 10.192 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/ws/src/runners/gearpump/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 19m 26s
31 actionable tasks: 31 executed
Publishing build scan...
https://gradle.com/s/ajmloxhm6tarm
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user amaliujia@163.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user mairbek@google.com
Not sending mail to unregistered user kirpichov@google.com