See <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/5544/display/redirect?page=changes>
Changes: [arietis27] [BEAM-13517] Unable to write nulls to columns with logical types ------------------------------------------ [...truncated 1.25 MB...] 21/12/23 12:11:53 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:44469 ... 21/12/23 12:11:53 INFO org.apache.beam.runners.fnexecution.data.GrpcDataService: Beam Fn Data client connected. 21/12/23 12:11:53 INFO org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory: Closing environment urn: "beam:env:docker:v1" payload: "\n\026apache/beam_go_sdk:dev" capabilities: "beam:protocol:progress_reporting:v0" capabilities: "beam:protocol:multi_core_bundle_processing:v1" capabilities: "beam:version:sdk_base:go" capabilities: "beam:coder:bytes:v1" capabilities: "beam:coder:bool:v1" capabilities: "beam:coder:varint:v1" capabilities: "beam:coder:double:v1" capabilities: "beam:coder:string_utf8:v1" capabilities: "beam:coder:length_prefix:v1" capabilities: "beam:coder:kv:v1" capabilities: "beam:coder:iterable:v1" capabilities: "beam:coder:state_backed_iterable:v1" capabilities: "beam:coder:windowed_value:v1" capabilities: "beam:coder:global_window:v1" capabilities: "beam:coder:interval_window:v1" capabilities: "beam:coder:row:v1" dependencies { type_urn: "beam:artifact:type:file:v1" type_payload: "\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn: "beam:artifact:role:staging_to:v1" role_payload: "\n\006worker" } 21/12/23 12:11:53 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: 1 Beam Fn Logging clients still connected during shutdown. 21/12/23 12:11:53 WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Hanged up for unknown endpoint. 21/12/23 12:11:53 INFO org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment: Closing Docker container c7614673ff4e786a7a6a8912964180d0bcadb872c61067c73af67ba6dffdeb7a. Logs: 2021/12/23 12:11:53 Provision info: pipeline_options:{fields:{key:"beam:option:app_name:v1" value:{string_value:"go-job-7-1640261510266989800"}} fields:{key:"beam:option:experiments:v1" value:{list_value:{values:{string_value:"beam_fn_api"}}}} fields:{key:"beam:option:go_options:v1" value:{struct_value:{fields:{key:"options" value:{struct_value:{fields:{key:"hookOrder" value:{string_value:"[\"default_remote_logging\"]"}} fields:{key:"hooks" value:{string_value:"{\"default_remote_logging\":null}"}}}}}}}} fields:{key:"beam:option:job_name:v1" value:{string_value:"go0job0701640261510266989800-jenkins-1223121151-7e76d8e"}} fields:{key:"beam:option:options_id:v1" value:{number_value:25}} fields:{key:"beam:option:parallelism:v1" value:{number_value:-1}} fields:{key:"beam:option:retain_docker_containers:v1" value:{bool_value:false}} fields:{key:"beam:option:runner:v1" value:{null_value:NULL_VALUE}} fields:{key:"beam:option:spark_master:v1" value:{string_value:"local"}}} logging_endpoint:{url:"localhost:34275"} artifact_endpoint:{url:"localhost:36093"} control_endpoint:{url:"localhost:39521"} dependencies:{type_urn:"beam:artifact:type:file:v1" type_payload:"\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn:"beam:artifact:role:staging_to:v1" role_payload:"\n\x06worker"} 2021/12/23 12:11:53 Initializing Go harness: /opt/apache/beam/boot --id=146-1 --provision_endpoint=localhost:46649 2021/12/23 12:11:53 Downloaded: /tmp/staged/worker (sha256: 687276aafb81de7ac213743521c6185ec6d9fd47b39e3cfd21c1857160a15311, size: 22772563) Worker exited successfully! 2021/12/23 12:11:53 control response channel closed Remote logging shutting down. 21/12/23 12:11:54 WARN org.apache.beam.runners.fnexecution.environment.DockerCommand: Unable to pull docker image apache/beam_go_sdk:dev, cause: Received exit code 1 for command 'docker pull apache/beam_go_sdk:dev'. stderr: Error response from daemon: manifest for apache/beam_go_sdk:dev not found 21/12/23 12:11:54 INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: Beam Fn Control client connected with id 147-1 21/12/23 12:11:54 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: Beam Fn Logging client connected. 21/12/23 12:11:54 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:39589 ... 21/12/23 12:11:54 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:40549 ... 21/12/23 12:11:54 INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: getProcessBundleDescriptor request with id 147-2 21/12/23 12:11:54 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:36377 ... 21/12/23 12:11:54 INFO org.apache.beam.runners.fnexecution.data.GrpcDataService: Beam Fn Data client connected. 21/12/23 12:11:54 INFO org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory: Closing environment urn: "beam:env:docker:v1" payload: "\n\026apache/beam_go_sdk:dev" capabilities: "beam:protocol:progress_reporting:v0" capabilities: "beam:protocol:multi_core_bundle_processing:v1" capabilities: "beam:version:sdk_base:go" capabilities: "beam:coder:bytes:v1" capabilities: "beam:coder:bool:v1" capabilities: "beam:coder:varint:v1" capabilities: "beam:coder:double:v1" capabilities: "beam:coder:string_utf8:v1" capabilities: "beam:coder:length_prefix:v1" capabilities: "beam:coder:kv:v1" capabilities: "beam:coder:iterable:v1" capabilities: "beam:coder:state_backed_iterable:v1" capabilities: "beam:coder:windowed_value:v1" capabilities: "beam:coder:global_window:v1" capabilities: "beam:coder:interval_window:v1" capabilities: "beam:coder:row:v1" dependencies { type_urn: "beam:artifact:type:file:v1" type_payload: "\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn: "beam:artifact:role:staging_to:v1" role_payload: "\n\006worker" } 21/12/23 12:11:54 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: 1 Beam Fn Logging clients still connected during shutdown. 21/12/23 12:11:55 WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Hanged up for unknown endpoint. 21/12/23 12:11:55 INFO org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment: Closing Docker container c2a6f08cc46bef59757a197fce757e4c53a2ea975c9412ae73480e7e526231f7. Logs: 2021/12/23 12:11:54 Provision info: pipeline_options:{fields:{key:"beam:option:app_name:v1" value:{string_value:"go-job-7-1640261510266989800"}} fields:{key:"beam:option:experiments:v1" value:{list_value:{values:{string_value:"beam_fn_api"}}}} fields:{key:"beam:option:go_options:v1" value:{struct_value:{fields:{key:"options" value:{struct_value:{fields:{key:"hookOrder" value:{string_value:"[\"default_remote_logging\"]"}} fields:{key:"hooks" value:{string_value:"{\"default_remote_logging\":null}"}}}}}}}} fields:{key:"beam:option:job_name:v1" value:{string_value:"go0job0701640261510266989800-jenkins-1223121151-7e76d8e"}} fields:{key:"beam:option:options_id:v1" value:{number_value:25}} fields:{key:"beam:option:parallelism:v1" value:{number_value:-1}} fields:{key:"beam:option:retain_docker_containers:v1" value:{bool_value:false}} fields:{key:"beam:option:runner:v1" value:{null_value:NULL_VALUE}} fields:{key:"beam:option:spark_master:v1" value:{string_value:"local"}}} logging_endpoint:{url:"localhost:40549"} artifact_endpoint:{url:"localhost:38489"} control_endpoint:{url:"localhost:39589"} dependencies:{type_urn:"beam:artifact:type:file:v1" type_payload:"\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn:"beam:artifact:role:staging_to:v1" role_payload:"\n\x06worker"} 2021/12/23 12:11:54 Initializing Go harness: /opt/apache/beam/boot --id=147-1 --provision_endpoint=localhost:40395 2021/12/23 12:11:54 Downloaded: /tmp/staged/worker (sha256: 687276aafb81de7ac213743521c6185ec6d9fd47b39e3cfd21c1857160a15311, size: 22772563) Worker exited successfully! 2021/12/23 12:11:54 control response channel closed Remote logging shutting down. 21/12/23 12:11:56 WARN org.apache.beam.runners.fnexecution.environment.DockerCommand: Unable to pull docker image apache/beam_go_sdk:dev, cause: Received exit code 1 for command 'docker pull apache/beam_go_sdk:dev'. stderr: Error response from daemon: manifest for apache/beam_go_sdk:dev not found 21/12/23 12:11:56 INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: Beam Fn Control client connected with id 148-1 21/12/23 12:11:56 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: Beam Fn Logging client connected. 21/12/23 12:11:56 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:46799 ... 21/12/23 12:11:56 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:45915 ... 21/12/23 12:11:56 INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: getProcessBundleDescriptor request with id 148-2 21/12/23 12:11:56 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:42343 ... 21/12/23 12:11:56 INFO org.apache.beam.runners.fnexecution.data.GrpcDataService: Beam Fn Data client connected. 21/12/23 12:11:56 INFO org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory: Closing environment urn: "beam:env:docker:v1" payload: "\n\026apache/beam_go_sdk:dev" capabilities: "beam:protocol:progress_reporting:v0" capabilities: "beam:protocol:multi_core_bundle_processing:v1" capabilities: "beam:version:sdk_base:go" capabilities: "beam:coder:bytes:v1" capabilities: "beam:coder:bool:v1" capabilities: "beam:coder:varint:v1" capabilities: "beam:coder:double:v1" capabilities: "beam:coder:string_utf8:v1" capabilities: "beam:coder:length_prefix:v1" capabilities: "beam:coder:kv:v1" capabilities: "beam:coder:iterable:v1" capabilities: "beam:coder:state_backed_iterable:v1" capabilities: "beam:coder:windowed_value:v1" capabilities: "beam:coder:global_window:v1" capabilities: "beam:coder:interval_window:v1" capabilities: "beam:coder:row:v1" dependencies { type_urn: "beam:artifact:type:file:v1" type_payload: "\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn: "beam:artifact:role:staging_to:v1" role_payload: "\n\006worker" } 21/12/23 12:11:56 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: 1 Beam Fn Logging clients still connected during shutdown. 21/12/23 12:11:56 WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Hanged up for unknown endpoint. 21/12/23 12:11:56 INFO org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment: Closing Docker container e228488a298fadcafd51396d9f41f33a53f0d44cae11581f00482ae9ad8bdde4. Logs: 2021/12/23 12:11:56 Provision info: pipeline_options:{fields:{key:"beam:option:app_name:v1" value:{string_value:"go-job-7-1640261510266989800"}} fields:{key:"beam:option:experiments:v1" value:{list_value:{values:{string_value:"beam_fn_api"}}}} fields:{key:"beam:option:go_options:v1" value:{struct_value:{fields:{key:"options" value:{struct_value:{fields:{key:"hookOrder" value:{string_value:"[\"default_remote_logging\"]"}} fields:{key:"hooks" value:{string_value:"{\"default_remote_logging\":null}"}}}}}}}} fields:{key:"beam:option:job_name:v1" value:{string_value:"go0job0701640261510266989800-jenkins-1223121151-7e76d8e"}} fields:{key:"beam:option:options_id:v1" value:{number_value:25}} fields:{key:"beam:option:parallelism:v1" value:{number_value:-1}} fields:{key:"beam:option:retain_docker_containers:v1" value:{bool_value:false}} fields:{key:"beam:option:runner:v1" value:{null_value:NULL_VALUE}} fields:{key:"beam:option:spark_master:v1" value:{string_value:"local"}}} logging_endpoint:{url:"localhost:45915"} artifact_endpoint:{url:"localhost:46707"} control_endpoint:{url:"localhost:46799"} dependencies:{type_urn:"beam:artifact:type:file:v1" type_payload:"\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn:"beam:artifact:role:staging_to:v1" role_payload:"\n\x06worker"} 2021/12/23 12:11:56 Initializing Go harness: /opt/apache/beam/boot --id=148-1 --provision_endpoint=localhost:35451 2021/12/23 12:11:56 Downloaded: /tmp/staged/worker (sha256: 687276aafb81de7ac213743521c6185ec6d9fd47b39e3cfd21c1857160a15311, size: 22772563) Worker exited successfully! 2021/12/23 12:11:56 control response channel closed Remote logging shutting down. 21/12/23 12:11:57 WARN org.apache.beam.runners.fnexecution.environment.DockerCommand: Unable to pull docker image apache/beam_go_sdk:dev, cause: Received exit code 1 for command 'docker pull apache/beam_go_sdk:dev'. stderr: Error response from daemon: manifest for apache/beam_go_sdk:dev not found 21/12/23 12:11:58 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: Beam Fn Logging client connected. 21/12/23 12:11:58 INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: Beam Fn Control client connected with id 149-1 21/12/23 12:11:58 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:45789 ... 21/12/23 12:11:58 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:36365 ... 21/12/23 12:11:58 INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: getProcessBundleDescriptor request with id 149-2 21/12/23 12:11:58 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:37759 ... 21/12/23 12:11:58 INFO org.apache.beam.runners.fnexecution.data.GrpcDataService: Beam Fn Data client connected. 21/12/23 12:11:58 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:40983 ... 21/12/23 12:11:58 INFO org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory: Closing environment urn: "beam:env:docker:v1" payload: "\n\026apache/beam_go_sdk:dev" capabilities: "beam:protocol:progress_reporting:v0" capabilities: "beam:protocol:multi_core_bundle_processing:v1" capabilities: "beam:version:sdk_base:go" capabilities: "beam:coder:bytes:v1" capabilities: "beam:coder:bool:v1" capabilities: "beam:coder:varint:v1" capabilities: "beam:coder:double:v1" capabilities: "beam:coder:string_utf8:v1" capabilities: "beam:coder:length_prefix:v1" capabilities: "beam:coder:kv:v1" capabilities: "beam:coder:iterable:v1" capabilities: "beam:coder:state_backed_iterable:v1" capabilities: "beam:coder:windowed_value:v1" capabilities: "beam:coder:global_window:v1" capabilities: "beam:coder:interval_window:v1" capabilities: "beam:coder:row:v1" dependencies { type_urn: "beam:artifact:type:file:v1" type_payload: "\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn: "beam:artifact:role:staging_to:v1" role_payload: "\n\006worker" } 21/12/23 12:11:58 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: 1 Beam Fn Logging clients still connected during shutdown. 21/12/23 12:11:58 WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Hanged up for unknown endpoint. 21/12/23 12:11:58 INFO org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment: Closing Docker container e624a9bc810b9a06435108538cf0467f2b39dbc9bbc8400bf394d046830cc50f. Logs: 2021/12/23 12:11:58 Provision info: pipeline_options:{fields:{key:"beam:option:app_name:v1" value:{string_value:"go-job-7-1640261510266989800"}} fields:{key:"beam:option:experiments:v1" value:{list_value:{values:{string_value:"beam_fn_api"}}}} fields:{key:"beam:option:go_options:v1" value:{struct_value:{fields:{key:"options" value:{struct_value:{fields:{key:"hookOrder" value:{string_value:"[\"default_remote_logging\"]"}} fields:{key:"hooks" value:{string_value:"{\"default_remote_logging\":null}"}}}}}}}} fields:{key:"beam:option:job_name:v1" value:{string_value:"go0job0701640261510266989800-jenkins-1223121151-7e76d8e"}} fields:{key:"beam:option:options_id:v1" value:{number_value:25}} fields:{key:"beam:option:parallelism:v1" value:{number_value:-1}} fields:{key:"beam:option:retain_docker_containers:v1" value:{bool_value:false}} fields:{key:"beam:option:runner:v1" value:{null_value:NULL_VALUE}} fields:{key:"beam:option:spark_master:v1" value:{string_value:"local"}}} logging_endpoint:{url:"localhost:36365"} artifact_endpoint:{url:"localhost:38801"} control_endpoint:{url:"localhost:45789"} dependencies:{type_urn:"beam:artifact:type:file:v1" type_payload:"\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn:"beam:artifact:role:staging_to:v1" role_payload:"\n\x06worker"} 2021/12/23 12:11:58 Initializing Go harness: /opt/apache/beam/boot --id=149-1 --provision_endpoint=localhost:46793 2021/12/23 12:11:58 Downloaded: /tmp/staged/worker (sha256: 687276aafb81de7ac213743521c6185ec6d9fd47b39e3cfd21c1857160a15311, size: 22772563) Worker exited successfully! 2021/12/23 12:11:58 control response channel closed Remote logging shutting down. 21/12/23 12:11:59 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Job go0job0701640261510266989800-jenkins-1223121151-7e76d8e_a1f1ad94-aa66-4da5-a467-396a3fd52015: Pipeline translated successfully. Computing outputs 21/12/23 12:11:59 WARN org.apache.beam.runners.fnexecution.environment.DockerCommand: Unable to pull docker image apache/beam_go_sdk:dev, cause: Received exit code 1 for command 'docker pull apache/beam_go_sdk:dev'. stderr: Error response from daemon: manifest for apache/beam_go_sdk:dev not found 21/12/23 12:12:00 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: Beam Fn Logging client connected. 21/12/23 12:12:00 INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: Beam Fn Control client connected with id 150-1 21/12/23 12:12:00 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:39175 ... 21/12/23 12:12:00 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:36531 ... 21/12/23 12:12:00 INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: getProcessBundleDescriptor request with id 150-2 21/12/23 12:12:00 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:43349 ... 21/12/23 12:12:00 INFO org.apache.beam.runners.fnexecution.data.GrpcDataService: Beam Fn Data client connected. 21/12/23 12:12:00 INFO <https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:539: Connecting via grpc @ localhost:36191 ... 21/12/23 12:12:00 INFO org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory: Closing environment urn: "beam:env:docker:v1" payload: "\n\026apache/beam_go_sdk:dev" capabilities: "beam:protocol:progress_reporting:v0" capabilities: "beam:protocol:multi_core_bundle_processing:v1" capabilities: "beam:version:sdk_base:go" capabilities: "beam:coder:bytes:v1" capabilities: "beam:coder:bool:v1" capabilities: "beam:coder:varint:v1" capabilities: "beam:coder:double:v1" capabilities: "beam:coder:string_utf8:v1" capabilities: "beam:coder:length_prefix:v1" capabilities: "beam:coder:kv:v1" capabilities: "beam:coder:iterable:v1" capabilities: "beam:coder:state_backed_iterable:v1" capabilities: "beam:coder:windowed_value:v1" capabilities: "beam:coder:global_window:v1" capabilities: "beam:coder:interval_window:v1" capabilities: "beam:coder:row:v1" dependencies { type_urn: "beam:artifact:type:file:v1" type_payload: "\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn: "beam:artifact:role:staging_to:v1" role_payload: "\n\006worker" } 21/12/23 12:12:00 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: 1 Beam Fn Logging clients still connected during shutdown. 21/12/23 12:12:00 WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Hanged up for unknown endpoint. 21/12/23 12:12:00 INFO org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment: Closing Docker container 79ab3191c0caa9b3fa6c9f2efb1208ce1ec085f1a8691b46d8d4f54e11993530. Logs: 2021/12/23 12:12:00 Provision info: pipeline_options:{fields:{key:"beam:option:app_name:v1" value:{string_value:"go-job-7-1640261510266989800"}} fields:{key:"beam:option:experiments:v1" value:{list_value:{values:{string_value:"beam_fn_api"}}}} fields:{key:"beam:option:go_options:v1" value:{struct_value:{fields:{key:"options" value:{struct_value:{fields:{key:"hookOrder" value:{string_value:"[\"default_remote_logging\"]"}} fields:{key:"hooks" value:{string_value:"{\"default_remote_logging\":null}"}}}}}}}} fields:{key:"beam:option:job_name:v1" value:{string_value:"go0job0701640261510266989800-jenkins-1223121151-7e76d8e"}} fields:{key:"beam:option:options_id:v1" value:{number_value:25}} fields:{key:"beam:option:parallelism:v1" value:{number_value:-1}} fields:{key:"beam:option:retain_docker_containers:v1" value:{bool_value:false}} fields:{key:"beam:option:runner:v1" value:{null_value:NULL_VALUE}} fields:{key:"beam:option:spark_master:v1" value:{string_value:"local"}}} logging_endpoint:{url:"localhost:36531"} artifact_endpoint:{url:"localhost:34805"} control_endpoint:{url:"localhost:39175"} dependencies:{type_urn:"beam:artifact:type:file:v1" type_payload:"\ng/tmp/beam-artifact-staging/b8b8d9979cc2766991146cb6985839b0cc2862d0e58dd9f9f353f4615958c1aa/1-go-worker" role_urn:"beam:artifact:role:staging_to:v1" role_payload:"\n\x06worker"} 2021/12/23 12:12:00 Initializing Go harness: /opt/apache/beam/boot --id=150-1 --provision_endpoint=localhost:42123 2021/12/23 12:12:00 Downloaded: /tmp/staged/worker (sha256: 687276aafb81de7ac213743521c6185ec6d9fd47b39e3cfd21c1857160a15311, size: 22772563) Worker exited successfully! 2021/12/23 12:12:00 control response channel closed Remote logging shutting down. 21/12/23 12:12:01 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Job go0job0701640261510266989800-jenkins-1223121151-7e76d8e_a1f1ad94-aa66-4da5-a467-396a3fd52015 finished. 2021/12/23 12:12:01 Job state: DONE 21/12/23 12:12:01 INFO org.apache.beam.runners.jobsubmission.InMemoryJobService: Getting job metrics for go0job0701640261510266989800-jenkins-1223121151-7e76d8e_a1f1ad94-aa66-4da5-a467-396a3fd52015 21/12/23 12:12:01 INFO org.apache.beam.runners.jobsubmission.InMemoryJobService: Finished getting job metrics for go0job0701640261510266989800-jenkins-1223121151-7e76d8e_a1f1ad94-aa66-4da5-a467-396a3fd52015 --- PASS: TestEmitParDoAfterGBK (10.94s) PASS ok github.com/apache/beam/sdks/v2/go/test/regression 66.955s FAIL > Task :sdks:go:test:sparkValidatesRunner FAILED FAILURE: Build failed with an exception. * Where: Build file '<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/ws/src/sdks/go/test/build.gradle'> line: 109 * What went wrong: Execution failed for task ':sdks:go:test:sparkValidatesRunner'. > Process 'command 'sh'' finished with non-zero exit value 1 * 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 7.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/6.9.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 11m 36s 83 actionable tasks: 51 executed, 29 from cache, 3 up-to-date Publishing build scan... https://gradle.com/s/chwmeggczrkqe Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
