See <https://builds.apache.org/job/beam_LoadTests_Python_GBK_Flink_Batch/215/display/redirect?page=changes>
Changes: [robertwb] [BEAM-6587] Remove hacks due to missing common string coder. [kirillkozlov] Update data source for SQL performance tests [chadrik] [BEAM-7746] Address changes in code since annotations were introduced [chadrik] [BEAM-7746] Typing fixes that require runtime code changes [chadrik] [BEAM-7746] Avoid creating attributes dynamically, so that they can be [chadrik] [BEAM-7746] Bugfix: coder id is expected to be str in python3 [chadrik] [BEAM-7746] Explicitly unpack tuple to avoid inferring unbounded tuple [chadrik] [BEAM-7746] Generate files with protobuf urns as part of gen_protos [chadrik] [BEAM-7746] Move name and coder to base StateSpec class [chadrik] [BEAM-7746] Remove reference to missing attribute in [chadrik] [BEAM-7746] Non-Optional arguments cannot default to None [chadrik] [BEAM-7746] Avoid reusing variables with different data types [chadrik] [BEAM-7746] Add StateHandler abstract base class [chadrik] [BEAM-7746] Add TODO about fixing assignment to [chadrik] [BEAM-7746] Fix functions that were defined twice [chadrik] [BEAM-7746] Fix tests that have the same name [iemejia] [BEAM-9040] Add skipQueries option to skip queries in a Nexmark suite [iemejia] [BEAM-9040] Add Spark Structured Streaming Runner to Nexmark PostCommit [valentyn] Switch to unittest.SkipTest instead of using nose. [mxm] [BEAM-6008] Make sure to end stream only after sending all messages and [chamikara] Sets the correct coder when clustering is enabled for the [robertwb] Always initalize output processor on construction. [github] [Go SDK Doc] Update Dead Container Link (#10585) [github] Merge pull request #10582 for [INFRA-19670] Add .asf.yaml for Github ------------------------------------------ [...truncated 274.62 KB...] value { bool_value: false } } fields { key: "beam:option:job_endpoint:v1" value { string_value: "localhost:8099" } } fields { key: "beam:option:job_name:v1" value { string_value: "load_tests_Python_Flink_Batch_GBK_3_0115100243" } } fields { key: "beam:option:job_port:v1" value { string_value: "0" } } fields { key: "beam:option:job_server_timeout:v1" value { string_value: "60" } } fields { key: "beam:option:load_balance_bundles:v1" value { bool_value: false } } 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:spark_master_url:v1" value { string_value: "local[4]" } } fields { key: "beam:option:spark_submit_uber_jar:v1" value { bool_value: false } } fields { key: "beam:option:streaming:v1" value { bool_value: false } } 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: 5499c081e0d62b74686ae1fc0fabba12) 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:84) 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.util.concurrent.ExecutionException: org.apache.beam.vendor.grpc.v1p21p0.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) at org.apache.beam.sdk.util.MoreFutures.get(MoreFutures.java:57) at org.apache.beam.runners.fnexecution.control.SdkHarnessClient$BundleProcessor$ActiveBundle.close(SdkHarnessClient.java:345) at org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.$closeResource(FlinkExecutableStageFunction.java:204) at org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.mapPartition(FlinkExecutableStageFunction.java:204) at org.apache.flink.runtime.operators.MapPartitionDriver.run(MapPartitionDriver.java:103) at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:504) at org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:369) at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530) ... 1 more Caused by: org.apache.beam.vendor.grpc.v1p21p0.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.Status.asRuntimeException(Status.java:524) at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:273) at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40) at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23) at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40) at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96) at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:337) at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:793) at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ... 1 more root: ERROR: org.apache.beam.vendor.grpc.v1p21p0.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close apache_beam.runners.portability.portable_runner: INFO: Job state changed to FAILED --------------------- >> end captured logging << --------------------- ---------------------------------------------------------------------- XML: <https://builds.apache.org/job/beam_LoadTests_Python_GBK_Flink_Batch/ws/src/sdks/python/nosetests.xml> ---------------------------------------------------------------------- Ran 1 test in 48.191s 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_GBK_Flink_Batch/ws/src/sdks/python/apache_beam/testing/load_tests/build.gradle'> line: 53 * 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 55s 5 actionable tasks: 3 executed, 2 up-to-date Publishing build scan... https://gradle.com/s/txcn3nvp4o3cu 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