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 amaliu...@163.com
Not sending mail to unregistered user git...@alasdairhodge.co.uk
Not sending mail to unregistered user mair...@google.com
Not sending mail to unregistered user kirpic...@google.com
