You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/12/01 02:02:52 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #1502
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/1502/display/redirect?page=changes>
Changes:
[ccy] [BEAM-6162] Fix PipelineOptions argparse behavior
------------------------------------------
[...truncated 15.87 MB...]
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager applicationReady
INFO: goto state ApplicationReady(dag = -1)...
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$3 applyOrElse
INFO: Broadcasting StartDynamicDag
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Broadcast StartDynamicDag to all executors
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ClockService$$anonfun$preStart$1 apply
INFO: Start Clock Retrieved, starting ClockService, startClock: -9223372036854775808
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.JarScheduler$JarSchedulerImpl$$anonfun$waitForNewDag$1 applyOrElse
INFO: Init JarScheduler, dag version: 0, startTime: -9223372036854775808
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager dynamicDag
INFO: DynamicDag transit to dag version: 0...
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.JarScheduler$JarSchedulerImpl$$anonfun$waitForNewDag$1$$anonfun$applyOrElse$1 apply
INFO: Set DAG for TaskScheduler, count: 78
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.JarScheduler$JarSchedulerImpl$$anonfun$ready$1 applyOrElse
INFO: GetRequestDetails ResourceRequestDetail(null,[Lorg.apache.gearpump.cluster.scheduler.ResourceRequest;@24c50605)
Dec 01, 2018 2:02:49 AM org.apache.gearpump.cluster.appmaster.ExecutorSystemScheduler$$anonfun$clientCommands$1 applyOrElse
INFO: starting executor systems (ExecutorSystemConfig(ExecutorSystemJvmConfig([Ljava.lang.String;@29eb5e6a,[Ljava.lang.String;@3e2324f7,Some(null),jenkins,Config(SimpleConfigObject({"akka":{"actor":{"default-dispatcher":{"fork-join-executor":{"parallelism-factor":2,"parallelism-max":4,"parallelism-min":4},"throughput":10},"default-mailbox":{"mailbox-type":"akka.dispatch.SingleConsumerOnlyUnboundedMailbox"},"kryo":{"buffer-size":4096,"classes":[],"compression":"off","idstrategy":"incremental","implicit-registration-logging":true,"kryo-reference-map":true,"kryo-trace":false,"max-buffer-size":-1,"serializer-pool-size":16,"type":"graph","use-manifests":false},"provider":"akka.cluster.ClusterActorRefProvider","warn-about-java-serializer-usage":false},"daemonic":"on","extensions":["org.apache.gearpump.transport.Express$","org.apache.gearpump.metrics.Metrics$"],"http":{"client":{"parsing":{"max-content-length":"2048m"}},"server":{"parsing":{"illegal-header-warnings":"off","max-content-length":"2048m"},"remote-address-header":"on"},"session":{"cookie":{"http-only":true,"name":"gearpump_token","path":"/","secure":false},"encrypt-data":true,"max-age":604800,"server-secret":"Please change this to a value only you know! At least 64 chars!!!"}},"io":{"tcp":{"windows-connection-abort-workaround-enabled":"off"}},"log-dead-letters":"off","log-dead-letters-during-shutdown":"off","loggers":["akka.event.slf4j.Slf4jLogger"],"logging-filter":"akka.event.slf4j.Slf4jLoggingFilter","loglevel":"INFO","remote":{"default-remote-dispatcher":{"executor":"fork-join-executor","throughput":5,"type":"Dispatcher"},"enabled-transports":["akka.remote.netty.tcp"],"log-remote-lifecycle-events":"off","netty":{"tcp":{"hostname":"127.0.0.1","maximum-frame-size":"2048000b","port":41523,"receive-buffer-size":"4096000b","send-buffer-size":"4096000b"}},"use-dispatcher":"akka.remote.default-remote-dispatcher"},"scheduler":{"tick-duration":1},"test":{"single-expect-default":"10s"}},"beamTestPipelineOptions":"[\"--runner=TestGearpumpRunner\",\"--streaming=true\"]","gearpump":{"application":{"executor-num":1,"total-retries":0},"appmaster":{"extraClasspath":"","vmargs":""},"cgroup":{"cpu-core-limit-per-executor":1,"root":"gearpump"},"cluster":{"masters":["127.0.0.1:41523"]},"executor":{"extraClasspath":"","vmargs":""},"home":"","hostname":"127.0.0.1","jarstore":{"rootpath":"jarstore/"},"log":{"application":{"dir":"logs"},"daemon":{"dir":"logs"}},"master-resource-manager-container-id":"","masterclient":{"timeout":90},"metrics":{"akka":{"max-limit-on-query":1000,"metrics-aggregator-class":{"org.apache.gearpump.streaming.metrics.ProcessorAggregator":"","org.apache.gearpump.streaming.metrics.TaskFilterAggregator":""}},"enabled":true,"graphite":{"host":"127.0.0.1","port":2003},"report-interval-ms":3000,"reporter":"akka","retainHistoryData":{"hours":72,"intervalMs":3600000},"retainRecentData":{"intervalMs":15000,"seconds":300},"sample-rate":1},"netty":{"base-sleep-ms":100,"buffer-size":5242880,"dispatcher":"gearpump.shared-thread-pool-dispatcher","flush-check-interval":5,"max-retries":30,"max-sleep-ms":1000,"message-batch-size":262144},"remote-debug-executor-jvm":false,"resource-allocation-timeout-seconds":120,"scheduling":{"scheduler-class":"org.apache.gearpump.cluster.scheduler.PriorityScheduler"},"serialization-framework":"org.apache.gearpump.serializer.FastKryoSerializationFramework","serializer":{"pool":"org.apache.gearpump.serializer.FastKryoSerializerPool"},"serializers":{"[B":"","[C":"","[D":"","[F":"","[I":"","[J":"","[Ljava.lang.String;":"","[S":"","[Z":"","akka.actor.LocalActorRef":"","scala.Array":"","scala.Tuple1":"","scala.Tuple2":"","scala.Tuple3":"","scala.Tuple4":"","scala.Tuple5":"","scala.Tuple6":"","scala.collection.immutable.$colon$colon":"","scala.collection.immutable.List":"","scala.collection.immutable.Vector":""},"services":{"config-render-option-concise":true,"host":"127.0.0.1","http":8090,"supervisor-actor-path":""},"shared-thread-pool-dispatcher":{"fork-join-executor":{"parallelism-factor":2,"parallelism-max":8,"parallelism-min":2},"mailbox-type":"akka.dispatch.SingleConsumerOnlyUnboundedMailbox","throughput":100},"single-thread-dispatcher":{"type":"PinnedDispatcher"},"start-executor-system-timeout-ms":120000,"streaming":{"ack-once-every-message-count":100,"max-pending-message-count-per-connection":1000,"register-task-timeout-ms":120000},"task-dispatcher":"gearpump.shared-thread-pool-dispatcher","transport":{"serializer":"org.apache.gearpump.streaming.task.StreamingTransportSerializer"},"ui-default-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"core-pool-size-factor":2,"core-pool-size-max":32,"core-pool-size-min":2},"throughput":1,"type":"Dispatcher"},"verbose-gc":false,"worker":{"executor-process-launcher":"org.apache.gearpump.cluster.worker.DefaultExecutorProcessLauncher","executor-share-same-jvm-as-worker":true,"slots":1000},"worker-resource-manager-container-id":"","yarn":{"applicationmaster":{"command":"$JAVA_HOME/bin/java -Xmx512m","memory":"512","queue":"default","vcores":"1"},"client":{"package-path":"/usr/lib/gearpump/gearpump.zip"},"master":{"command":"$JAVA_HOME/bin/java -Xmx512m","memory":"512","vcores":"1"},"services":{"enabled":true},"worker":{"command":"$JAVA_HOME/bin/java -Xmx512m","containers":"1","memory":"4096","vcores":"1"}}},"org":{"gradle":{"native":"false","test":{"worker":"1"}}}})))), Resources(ResourceRequest(Resource(78),WorkerId(-1,0),NORMAL,ANY,1)))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.cluster.scheduler.PriorityScheduler$$anonfun$resourceRequestHandler$1 applyOrElse
INFO: Request resource: appId: 1, slots: 78, relaxation: ANY, executor number: 1
Dec 01, 2018 2:02:49 AM org.apache.gearpump.cluster.appmaster.ExecutorSystemLauncher$$anonfun$waitForLaunchCommand$1 applyOrElse
INFO: Launching Executor ...appId: 1, executorSystemId: 0, slots: 78 on worker WorkerInfo(WorkerId(0,1543629332138),Actor[akka://master/user/Worker0#1313294111])
Dec 01, 2018 2:02:49 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: LaunchExecutor(1,0,Resource(78),ExecutorJVMConfig([Ljava.lang.String;@29eb5e6a,[Ljava.lang.String;@3e2324f7,org.apache.gearpump.util.ActorSystemBooter,[Ljava.lang.String;@7c2eb429,Some(null),jenkins,Config(SimpleConfigObject({"akka":{"actor":{"default-dispatcher":{"fork-join-executor":{"parallelism-factor":2,"parallelism-max":4,"parallelism-min":4},"throughput":10},"default-mailbox":{"mailbox-type":"akka.dispatch.SingleConsumerOnlyUnboundedMailbox"},"kryo":{"buffer-size":4096,"classes":[],"compression":"off","idstrategy":"incremental","implicit-registration-logging":true,"kryo-reference-map":true,"kryo-trace":false,"max-buffer-size":-1,"serializer-pool-size":16,"type":"graph","use-manifests":false},"provider":"akka.cluster.ClusterActorRefProvider","warn-about-java-serializer-usage":false},"daemonic":"on","extensions":["org.apache.gearpump.transport.Express$","org.apache.gearpump.metrics.Metrics$"],"http":{"client":{"parsing":{"max-content-length":"2048m"}},"server":{"parsing":{"illegal-header-warnings":"off","max-content-length":"2048m"},"remote-address-header":"on"},"session":{"cookie":{"http-only":true,"name":"gearpump_token","path":"/","secure":false},"encrypt-data":true,"max-age":604800,"server-secret":"Please change this to a value only you know! At least 64 chars!!!"}},"io":{"tcp":{"windows-connection-abort-workaround-enabled":"off"}},"log-dead-letters":"off","log-dead-letters-during-shutdown":"off","loggers":["akka.event.slf4j.Slf4jLogger"],"logging-filter":"akka.event.slf4j.Slf4jLoggingFilter","loglevel":"INFO","remote":{"default-remote-dispatcher":{"executor":"fork-join-executor","throughput":5,"type":"Dispatcher"},"enabled-transports":["akka.remote.netty.tcp"],"log-remote-lifecycle-events":"off","netty":{"tcp":{"hostname":"127.0.0.1","maximum-frame-size":"2048000b","port":41523,"receive-buffer-size":"4096000b","send-buffer-size":"4096000b"}},"use-dispatcher":"akka.remote.default-remote-dispatcher"},"scheduler":{"tick-duration":1},"test":{"single-expect-default":"10s"}},"beamTestPipelineOptions":"[\"--runner=TestGearpumpRunner\",\"--streaming=true\"]","gearpump":{"application":{"executor-num":1,"total-retries":0},"appmaster":{"extraClasspath":"","vmargs":""},"cgroup":{"cpu-core-limit-per-executor":1,"root":"gearpump"},"cluster":{"masters":["127.0.0.1:41523"]},"executor":{"extraClasspath":"","vmargs":""},"home":"","hostname":"127.0.0.1","jarstore":{"rootpath":"jarstore/"},"log":{"application":{"dir":"logs"},"daemon":{"dir":"logs"}},"master-resource-manager-container-id":"","masterclient":{"timeout":90},"metrics":{"akka":{"max-limit-on-query":1000,"metrics-aggregator-class":{"org.apache.gearpump.streaming.metrics.ProcessorAggregator":"","org.apache.gearpump.streaming.metrics.TaskFilterAggregator":""}},"enabled":true,"graphite":{"host":"127.0.0.1","port":2003},"report-interval-ms":3000,"reporter":"akka","retainHistoryData":{"hours":72,"intervalMs":3600000},"retainRecentData":{"intervalMs":15000,"seconds":300},"sample-rate":1},"netty":{"base-sleep-ms":100,"buffer-size":5242880,"dispatcher":"gearpump.shared-thread-pool-dispatcher","flush-check-interval":5,"max-retries":30,"max-sleep-ms":1000,"message-batch-size":262144},"remote-debug-executor-jvm":false,"resource-allocation-timeout-seconds":120,"scheduling":{"scheduler-class":"org.apache.gearpump.cluster.scheduler.PriorityScheduler"},"serialization-framework":"org.apache.gearpump.serializer.FastKryoSerializationFramework","serializer":{"pool":"org.apache.gearpump.serializer.FastKryoSerializerPool"},"serializers":{"[B":"","[C":"","[D":"","[F":"","[I":"","[J":"","[Ljava.lang.String;":"","[S":"","[Z":"","akka.actor.LocalActorRef":"","scala.Array":"","scala.Tuple1":"","scala.Tuple2":"","scala.Tuple3":"","scala.Tuple4":"","scala.Tuple5":"","scala.Tuple6":"","scala.collection.immutable.$colon$colon":"","scala.collection.immutable.List":"","scala.collection.immutable.Vector":""},"services":{"config-render-option-concise":true,"host":"127.0.0.1","http":8090,"supervisor-actor-path":""},"shared-thread-pool-dispatcher":{"fork-join-executor":{"parallelism-factor":2,"parallelism-max":8,"parallelism-min":2},"mailbox-type":"akka.dispatch.SingleConsumerOnlyUnboundedMailbox","throughput":100},"single-thread-dispatcher":{"type":"PinnedDispatcher"},"start-executor-system-timeout-ms":120000,"streaming":{"ack-once-every-message-count":100,"max-pending-message-count-per-connection":1000,"register-task-timeout-ms":120000},"task-dispatcher":"gearpump.shared-thread-pool-dispatcher","transport":{"serializer":"org.apache.gearpump.streaming.task.StreamingTransportSerializer"},"ui-default-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"core-pool-size-factor":2,"core-pool-size-max":32,"core-pool-size-min":2},"throughput":1,"type":"Dispatcher"},"verbose-gc":false,"worker":{"executor-process-launcher":"org.apache.gearpump.cluster.worker.DefaultExecutorProcessLauncher","executor-share-same-jvm-as-worker":true,"slots":1000},"worker-resource-manager-container-id":"","yarn":{"applicationmaster":{"command":"$JAVA_HOME/bin/java -Xmx512m","memory":"512","queue":"default","vcores":"1"},"client":{"package-path":"/usr/lib/gearpump/gearpump.zip"},"master":{"command":"$JAVA_HOME/bin/java -Xmx512m","memory":"512","vcores":"1"},"services":{"enabled":true},"worker":{"command":"$JAVA_HOME/bin/java -Xmx512m","containers":"1","memory":"4096","vcores":"1"}}},"org":{"gradle":{"native":"false","test":{"worker":"1"}}}}))))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.cluster.scheduler.Scheduler$$anonfun$handleScheduleMessage$1 applyOrElse
INFO: ResourceUpdate(Actor[akka://master/user/Worker0#1313294111],WorkerId(0,1543629332138),Resource(921))...
Dec 01, 2018 2:02:49 AM org.apache.gearpump.cluster.worker.Worker$$anonfun$appMasterMsgHandler$1 applyOrElse
INFO: Update resource succeed
Dec 01, 2018 2:02:49 AM org.apache.gearpump.util.ActorSystemBooter$Daemon <init>
INFO: RegisterActorSystem to akka.tcp://master@127.0.0.1:41523/user/Worker0/$c/$a/appdaemon1/$b/$a/$b, current user: not_defined
Dec 01, 2018 2:02:49 AM org.apache.gearpump.cluster.appmaster.ExecutorSystemLauncher$$anonfun$waitForActorSystemToStart$1 applyOrElse
INFO: Received RegisterActorSystem akka.tcp://master@127.0.0.1:41523 for session Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors#-1606870334]
Dec 01, 2018 2:02:49 AM org.apache.gearpump.cluster.appmaster.ExecutorSystemScheduler$$anonfun$executorSystemMessageHandler$1 applyOrElse
INFO: LaunchExecutorSystemSuccess, send back to Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors#-1606870334]
Dec 01, 2018 2:02:49 AM org.apache.gearpump.util.ActorSystemBooter$Daemon$$anonfun$waitCommand$1 applyOrElse
INFO: ActorSystem app1system0 Binding life cycle with actor: Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$b/$a#-1006943043]
Dec 01, 2018 2:02:49 AM org.apache.gearpump.util.ActorSystemBooter$Daemon$$anonfun$waitCommand$1 applyOrElse
INFO: ActorSystem app1system0 Binding life cycle with actor: Actor[akka://master/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors/0#2117400037]
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.executor.Executor <init>
INFO: Executor 0 has been started, start to register itself...
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.executor.Executor <init>
INFO: Executor actor path: akka.tcp://master@127.0.0.1:41523/user/Worker0/$c/$a/appdaemon1/$c/appmaster/executors/0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: executor 0 has been launched
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.JarScheduler$JarSchedulerImpl$$anonfun$ready$1 applyOrElse
INFO: ScheduleTask TaskId(62,0);TaskId(68,0);TaskId(15,0);TaskId(47,0);TaskId(4,0);TaskId(19,0);TaskId(51,0);TaskId(30,0);TaskId(36,0);TaskId(58,0);TaskId(75,0);TaskId(8,0);TaskId(23,0);TaskId(55,0);TaskId(26,0);TaskId(40,0);TaskId(43,0);TaskId(72,0);TaskId(11,0);TaskId(31,0);TaskId(16,0);TaskId(67,0);TaskId(50,0);TaskId(18,0);TaskId(63,0);TaskId(48,0);TaskId(35,0);TaskId(3,0);TaskId(66,0);TaskId(39,0);TaskId(7,0);TaskId(76,0);TaskId(49,0);TaskId(54,0);TaskId(12,0);TaskId(71,0);TaskId(27,0);TaskId(59,0);TaskId(44,0);TaskId(22,0);TaskId(17,0);TaskId(64,0);TaskId(45,0);TaskId(34,0);TaskId(32,0);TaskId(2,0);TaskId(73,0);TaskId(41,0);TaskId(13,0);TaskId(77,0);TaskId(53,0);TaskId(9,0);TaskId(65,0);TaskId(33,0);TaskId(21,0);TaskId(70,0);TaskId(38,0);TaskId(28,0);TaskId(60,0);TaskId(6,0);TaskId(74,0);TaskId(1,0);TaskId(61,0);TaskId(29,0);TaskId(57,0);TaskId(46,0);TaskId(20,0);TaskId(14,0);TaskId(52,0);TaskId(25,0);TaskId(37,0);TaskId(24,0);TaskId(42,0);TaskId(56,0);TaskId(10,0);TaskId(5,0);TaskId(0,0);TaskId(69,0)
Dec 01, 2018 2:02:49 AM org.apache.gearpump.metrics.MetricsReporterService getReporter
INFO: Metrics reporter is enabled, using akka reporter
Dec 01, 2018 2:02:49 AM org.apache.gearpump.metrics.AkkaReporter <init>
INFO: Start Metrics AkkaReporter
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1$$anonfun$applyOrElse$5 apply
INFO: Executor ExecutorStarted(0,Resource(78),WorkerId(0,1543629332138),Some(null)) has been started, start to schedule tasks: TaskId(62,0),TaskId(68,0),TaskId(15,0),TaskId(47,0),TaskId(4,0),TaskId(19,0),TaskId(51,0),TaskId(30,0),TaskId(36,0),TaskId(58,0),TaskId(75,0),TaskId(8,0),TaskId(23,0),TaskId(55,0),TaskId(26,0),TaskId(40,0),TaskId(43,0),TaskId(72,0),TaskId(11,0),TaskId(31,0),TaskId(16,0),TaskId(67,0),TaskId(50,0),TaskId(18,0),TaskId(63,0),TaskId(48,0),TaskId(35,0),TaskId(3,0),TaskId(66,0),TaskId(39,0),TaskId(7,0),TaskId(76,0),TaskId(49,0),TaskId(54,0),TaskId(12,0),TaskId(71,0),TaskId(27,0),TaskId(59,0),TaskId(44,0),TaskId(22,0),TaskId(17,0),TaskId(64,0),TaskId(45,0),TaskId(34,0),TaskId(32,0),TaskId(2,0),TaskId(73,0),TaskId(41,0),TaskId(13,0),TaskId(77,0),TaskId(53,0),TaskId(9,0),TaskId(65,0),TaskId(33,0),TaskId(21,0),TaskId(70,0),TaskId(38,0),TaskId(28,0),TaskId(60,0),TaskId(6,0),TaskId(74,0),TaskId(1,0),TaskId(61,0),TaskId(29,0),TaskId(57,0),TaskId(46,0),TaskId(20,0),TaskId(14,0),TaskId(52,0),TaskId(25,0),TaskId(37,0),TaskId(24,0),TaskId(42,0),TaskId(56,0),TaskId(10,0),TaskId(5,0),TaskId(0,0),TaskId(69,0)
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 69, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 0, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(69,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 5, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(0,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.executor.Executor$$anonfun$applicationReady$1 applyOrElse
INFO: received LaunchTasks(List(TaskId(69,0)),0,ProcessorDescription(69,org.apache.gearpump.streaming.dsl.task.GroupByTask,1,group_by_Key_and_Window.org.apache.beam.sdk.transforms.windowing.GlobalWindows.keyed_by_timestamp.merge.values.map_to_RawUnionValue.fold_to_iterable.flatMap.filter_by_output_tag.from_RawUnionValue.map_to_RawUnionValue.fold_to_iterable.flatMap.filter_by_output_tag.from_RawUnionValue.map_to_RawUnionValue,org.apache.gearpump.cluster.UserConfig@193d952,LifeTime(-9223372036854775808,9223372036854775807),null),List(Subscriber(74,PartitionerDescription(org.apache.gearpump.streaming.partitioner.PartitionerObject@5447985e),1,LifeTime(-9223372036854775808,9223372036854775807)))), Executor transit to dag version: 0 from current version -1
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 10, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(69,0)) for app: 1
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(5,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 56, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(10,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 42, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(56,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(42,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 24, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 37, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(24,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 25, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(0,0)) for app: 1
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(37,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 52, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(25,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.TaskManager$$anonfun$startDag$1 applyOrElse
INFO: Start tasks on Executor(0), tasks: List(TaskId(52,0))
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 14, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.ExecutorManager$$anonfun$service$1 applyOrElse
INFO: Unicast LaunchTasks to executor 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(5,0)) for app: 1
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 20, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 46, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 57, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 29, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 61, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 1, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 74, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 6, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.appmaster.DagManager$$anonfun$dagService$1$$anonfun$applyOrElse$2 apply
INFO: Get task launcher data for processor: 60, dagVersion: 0
Dec 01, 2018 2:02:49 AM org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1 applyOrElse
INFO: Launching Task List(TaskId(10,0)) for app: 1
Uncaught error from thread [master-akka.actor.default-dispatcher-5] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
Uncaught error from thread [master-akka.actor.default-dispatcher-4] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
Uncaught error from thread [master-akka.actor.default-dispatcher-2] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
Uncaught error from thread [master-akka.actor.default-dispatcher-3] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[master]
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:717)
at scala.concurrent.forkjoin.ForkJoinPool.tryAddWorker(ForkJoinPool.java:1672)
at scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
at scala.concurrent.forkjoin.ForkJoinPool.fullExternalPush(ForkJoinPool.java:1905)
at scala.concurrent.forkjoin.ForkJoinPool.externalPush(ForkJoinPool.java:1834)
at scala.concurrent.forkjoin.ForkJoinPool.execute(ForkJoinPool.java:2955)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool.execute(AbstractDispatcher.scala:401)
at akka.dispatch.ExecutorServiceDelegate$class.execute(ThreadPoolBuilder.scala:211)
at akka.dispatch.Dispatcher$LazyExecutorServiceDelegate.execute(Dispatcher.scala:39)
at akka.dispatch.Dispatcher.registerForExecution(Dispatcher.scala:115)
at akka.dispatch.MessageDispatcher.attach(AbstractDispatcher.scala:133)
at akka.actor.dungeon.Dispatch$class.start(Dispatch.scala:100)
at akka.actor.ActorCell.start(ActorCell.scala:374)
at akka.actor.LocalActorRef.start(ActorRef.scala:343)
at akka.actor.dungeon.Children$class.makeChild(Children.scala:287)
at akka.actor.dungeon.Children$class.actorOf(Children.scala:42)
at akka.actor.ActorCell.actorOf(ActorCell.scala:374)
at org.apache.gearpump.streaming.executor.TaskLauncher.launch(TaskLauncher.scala:63)
at org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1.applyOrElse(Executor.scala:156)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at akka.actor.Actor$class.aroundReceive(Actor.scala:496)
at org.apache.gearpump.streaming.executor.Executor.aroundReceive(Executor.scala:54)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
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)
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:717)
at scala.concurrent.forkjoin.ForkJoinPool.tryAddWorker(ForkJoinPool.java:1672)
at scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
at scala.concurrent.forkjoin.ForkJoinPool.fullExternalPush(ForkJoinPool.java:1905)
at scala.concurrent.forkjoin.ForkJoinPool.externalPush(ForkJoinPool.java:1834)
at scala.concurrent.forkjoin.ForkJoinPool.execute(ForkJoinPool.java:2955)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool.execute(AbstractDispatcher.scala:401)
at akka.dispatch.ExecutorServiceDelegate$class.execute(ThreadPoolBuilder.scala:211)
at akka.dispatch.Dispatcher$LazyExecutorServiceDelegate.execute(Dispatcher.scala:39)
at akka.dispatch.Dispatcher.registerForExecution(Dispatcher.scala:115)
at akka.dispatch.MessageDispatcher.attach(AbstractDispatcher.scala:133)
at akka.actor.dungeon.Dispatch$class.start(Dispatch.scala:100)
at akka.actor.ActorCell.start(ActorCell.scala:374)
at akka.actor.LocalActorRef.start(ActorRef.scala:343)
at akka.actor.dungeon.Children$class.makeChild(Children.scala:287)
at akka.actor.dungeon.Children$class.actorOf(Children.scala:42)
at akka.actor.ActorCell.actorOf(ActorCell.scala:374)
at org.apache.gearpump.streaming.executor.TaskLauncher.launch(TaskLauncher.scala:63)
at org.apache.gearpump.streaming.executor.Executor$$anonfun$dynamicDagPhase1$1.applyOrElse(Executor.scala:156)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at akka.actor.Actor$class.aroundReceive(Actor.scala:496)
at org.apache.gearpump.streaming.executor.Executor.aroundReceive(Executor.scala:54)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSourceSplits SKIPPED
> Task :beam-runners-gearpump:validatesRunnerStreaming FAILED
:beam-runners-gearpump:validatesRunnerStreaming (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 21 mins 48.472 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-gearpump:validatesRunnerStreaming'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 255
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 22m 58s
36 actionable tasks: 32 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/cv54ya5iyq6lk
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal :
beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle #1503
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/1503/display/redirect>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org