See <https://builds.apache.org/job/beam_LoadTests_Python_coGBK_Flink_Batch/133/display/redirect?page=changes>
Changes: [ehudm] [BEAM-8662] Remove Py3 annotations support from [sniemitz] [BEAM-8809] Make the constructor for AvroWriteRequest public [suztomo] Hadoop client 2.8 [suztomo] Elasticsearch-hadoop's use of commons-httpclient [crites] Adds translation support for TestStream to Dataflow Java runner. [crites] Formatting cleanup using gradlew spotnessApply. [github] [BEAM-8481] Revert the increase in Postcommit timeout [lcwik] [BEAM-4287] Add trySplit API to Java restriction tracker matching Python [suztomo] Hardcoding dfs.nameservices [suztomo] Updated comment [suztomo] Fixed unused import [lcwik] fixup! [github] Add a comment on RLock perf issues [lcwik] fixup! [wenjialiu] [BEAM-8575] test_flatten_no_pcollection raises an exception and should [ehudm] Moving to 2.19.0-SNAPSHOT on master branch. [chamikara] [BEAM-8884] Fix mongodb splitVector command result type issue (#10282) [github] Merge pull request #10247: [BEAM-7274] In preparation for [lgajowy] [BEAM-6627] Add size reporting to JdbcIOIT (#10267) ------------------------------------------ [...truncated 210.58 KB...] string_value: "0" } } fields { key: "beam:option:job_server_timeout:v1" value { string_value: "60" } } fields { key: "beam:option:no_auth:v1" value { bool_value: false } } fields { key: "beam:option:object_reuse:v1" value { bool_value: false } } fields { key: "beam:option:parallelism:v1" value { string_value: "5" } } fields { key: "beam:option:pipeline_type_check:v1" value { bool_value: true } } fields { key: "beam:option:profile_cpu:v1" value { bool_value: false } } fields { key: "beam:option:profile_memory:v1" value { bool_value: false } } fields { key: "beam:option:profile_sample_rate:v1" value { number_value: 1.0 } } fields { key: "beam:option:project:v1" value { string_value: "apache-beam-testing" } } fields { key: "beam:option:retain_docker_containers:v1" value { bool_value: false } } fields { key: "beam:option:retain_externalized_checkpoints_on_cancellation:v1" value { bool_value: false } } fields { key: "beam:option:runtime_type_check:v1" value { bool_value: false } } fields { key: "beam:option:save_main_session:v1" value { bool_value: false } } fields { key: "beam:option:sdk_location:v1" value { string_value: "container" } } fields { key: "beam:option:sdk_worker_parallelism:v1" value { string_value: "1" } } fields { key: "beam:option:shutdown_sources_on_final_watermark:v1" value { bool_value: false } } fields { key: "beam:option:streaming:v1" value { bool_value: false } } fields { key: "beam:option:temp_location:v1" value { string_value: "gs://temp-storage-for-perf-tests/loadtests" } } fields { key: "beam:option:type_check_strictness:v1" value { string_value: "DEFAULT_TO_ANY" } } fields { key: "beam:option:update:v1" value { bool_value: false } } } job_name: "job" apache_beam.runners.portability.portable_runner: INFO: Job state changed to STOPPED apache_beam.runners.portability.portable_runner: INFO: Job state changed to STARTING apache_beam.runners.portability.portable_runner: INFO: Job state changed to RUNNING root: DEBUG: org.apache.flink.client.program.ProgramInvocationException: Job failed. (JobID: 805bd4e9cb42f76cfd7f3a3d86521251) at org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:262) at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:338) at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:326) at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:301) at org.apache.flink.client.RemoteExecutor.executePlanWithJars(RemoteExecutor.java:209) at org.apache.flink.client.RemoteExecutor.executePlan(RemoteExecutor.java:186) at org.apache.flink.api.java.RemoteEnvironment.execute(RemoteEnvironment.java:173) at org.apache.beam.runners.flink.FlinkBatchPortablePipelineTranslator$BatchTranslationContext.execute(FlinkBatchPortablePipelineTranslator.java:191) at org.apache.beam.runners.flink.FlinkPipelineRunner.runPipelineWithTranslator(FlinkPipelineRunner.java:116) at org.apache.beam.runners.flink.FlinkPipelineRunner.run(FlinkPipelineRunner.java:84) at org.apache.beam.runners.fnexecution.jobsubmission.JobInvocation.runPipeline(JobInvocation.java:81) at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:125) at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:57) at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:78) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146) at org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:259) ... 16 more Caused by: java.lang.IllegalStateException: Update to task [GroupReduce (GroupReduce at CoGroupByKey /GroupByKey) (4/5) - execution #0] on TaskManager container_e01_1575562626451_0001_01_000006 @ beam-loadtests-python-cogbk-flink-batch-133-w-0.c.apache-beam-testing.internal (dataPort=34921) failed at org.apache.flink.runtime.executiongraph.Execution.lambda$sendUpdatePartitionInfoRpcCall$14(Execution.java:1395) at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:397) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:190) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) 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 akka.actor.Actor$class.aroundReceive(Actor.scala:517) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) at akka.actor.ActorCell.invoke(ActorCell.scala:561) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) at akka.dispatch.Mailbox.run(Mailbox.scala:225) at akka.dispatch.Mailbox.exec(Mailbox.scala:235) at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Caused by: java.util.concurrent.CompletionException: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@beam-loadtests-python-cogbk-flink-batch-133-w-0.c.apache-beam-testing.internal:35073/user/taskmanager_0#-1541334368]] after [10000 ms]. Message of type [org.apache.flink.runtime.rpc.messages.RemoteRpcInvocation]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply. at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607) at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591) at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:871) at akka.dispatch.OnComplete.internal(Future.scala:263) at akka.dispatch.OnComplete.internal(Future.scala:261) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:644) at akka.actor.Scheduler$$anon$4.run(Scheduler.scala:205) at scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:601) at scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109) at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:599) at akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:328) at akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:279) at akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:283) at akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:235) at java.lang.Thread.run(Thread.java:748) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@beam-loadtests-python-cogbk-flink-batch-133-w-0.c.apache-beam-testing.internal:35073/user/taskmanager_0#-1541334368]] after [10000 ms]. Message of type [org.apache.flink.runtime.rpc.messages.RemoteRpcInvocation]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply. at akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635) at akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635) at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:648) ... 9 more root: ERROR: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@beam-loadtests-python-cogbk-flink-batch-133-w-0.c.apache-beam-testing.internal:35073/user/taskmanager_0#-1541334368]] after [10000 ms]. Message of type [org.apache.flink.runtime.rpc.messages.RemoteRpcInvocation]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply. apache_beam.runners.portability.portable_runner: INFO: Job state changed to FAILED --------------------- >> end captured logging << --------------------- ---------------------------------------------------------------------- XML: <https://builds.apache.org/job/beam_LoadTests_Python_coGBK_Flink_Batch/ws/src/sdks/python/nosetests.xml> ---------------------------------------------------------------------- Ran 1 test in 744.626s FAILED (errors=1) > Task :sdks:python:apache_beam:testing:load_tests:run FAILED FAILURE: Build failed with an exception. * Where: Build file '<https://builds.apache.org/job/beam_LoadTests_Python_coGBK_Flink_Batch/ws/src/sdks/python/apache_beam/testing/load_tests/build.gradle'> line: 55 * What went wrong: Execution failed for task ':sdks:python:apache_beam:testing:load_tests:run'. > error occurred * Try: Run with --stacktrace option to get the stack trace. Run with --info or --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 6.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 12m 34s 3 actionable tasks: 2 executed, 1 up-to-date Publishing build scan... https://scans.gradle.com/s/oq6gw7kcsb3ok Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org For additional commands, e-mail: builds-h...@beam.apache.org