See <https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/6801/display/redirect?page=changes>
Changes: [noreply] Add timeout to unit tests causing SickBay PostCommit timeout (#25664) ------------------------------------------ [...truncated 70.94 KB...] 2023/03/02 17:05:08 INFO no more pending elements: terminating pipeline 2023/03/02 17:05:08 INFO pipeline done! job=job-021[go-job-21-1677776708666068471] 2023/03/02 17:05:08 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40165 2023/03/02 17:05:08 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40165 2023/03/02 17:05:08 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40165 2023/03/02 17:05:08 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40165 2023/03/02 17:05:08 INFO environment stopped envID=worker[go] job=job-021[go-job-21-1677776708666068471] 2023/03/02 17:05:08 INFO Serving Worker components endpoint=[::]:44411 2023/03/02 17:05:08 INFO Connecting via grpc @ [::]:44411 for control ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:08.834Z worker.ID=go worker.endpoint=[::]:44411 2023/03/02 17:05:08 INFO Connecting via grpc @ [::]:44411 for logging ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:08.835Z worker.ID=go worker.endpoint=[::]:44411 2023/03/02 17:05:08 INFO Connecting via grpc @ [::]:44411 for data ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:08.837Z worker.ID=go worker.endpoint=[::]:44411 2023/03/02 17:05:08 INFO Connecting via grpc @ [::]:44411 for state ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:08.879Z worker.ID=go worker.endpoint=[::]:44411 2023/03/02 17:05:08 INFO no more pending elements: terminating pipeline 2023/03/02 17:05:08 INFO pipeline done! job=job-022[go-job-22-1677776708821331900] 2023/03/02 17:05:08 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44411 2023/03/02 17:05:08 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44411 2023/03/02 17:05:08 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44411 2023/03/02 17:05:08 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44411 2023/03/02 17:05:08 INFO environment stopped envID=worker[go] job=job-022[go-job-22-1677776708821331900] 2023/03/02 17:05:08 INFO Serving Worker components endpoint=[::]:40215 2023/03/02 17:05:08 INFO Connecting via grpc @ [::]:40215 for control ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:08.931Z worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:08 INFO Connecting via grpc @ [::]:40215 for logging ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:08.931Z worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:08 INFO Job state: STOPPED source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:117 time=2023-03-02T17:05:08.933Z worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:08 INFO Job state: STARTING source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:117 time=2023-03-02T17:05:08.933Z worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:08 INFO (): starting job-023[go-job-23-1677776708922452641] source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:104 time=2023-03-02T17:05:08.933Z worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:08 INFO (): running job-023[go-job-23-1677776708922452641] source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:104 time=2023-03-02T17:05:08.933Z worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:08 INFO Job state: RUNNING source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:117 time=2023-03-02T17:05:08.933Z worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:08 INFO Connecting via grpc @ [::]:40215 for data ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:08.938Z worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:08 INFO Connecting via grpc @ [::]:40215 for state ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:08.989Z worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:09 INFO no more pending elements: terminating pipeline 2023/03/02 17:05:09 INFO pipeline done! job=job-023[go-job-23-1677776708922452641] 2023/03/02 17:05:09 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:09 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:09 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:09 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40215 2023/03/02 17:05:09 control response channel closed 2023/03/02 17:05:09 INFO environment stopped envID=worker[go] job=job-023[go-job-23-1677776708922452641] 2023/03/02 17:05:09 Warning: 24 errors during metrics processing: [failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x06" labels:{key:"PCOLLECTION" value:"ns8_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x05" labels:{key:"PCOLLECTION" value:"ns12_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x03]\x1f\x1f" labels:{key:"PCOLLECTION" value:"ns8_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x05" labels:{key:"PCOLLECTION" value:"ns12_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\n\xc3\x01\x08\x1f" labels:{key:"PCOLLECTION" value:"ns12_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x03" labels:{key:"PCOLLECTION" value:"ns4_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x02" labels:{key:"PCOLLECTION" value:"ns16_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x06u\x08\x1f" labels:{key:"PCOLLECTION" value:"ns4_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x05\x9b\x01\x1f\x1f" labels:{key:"PCOLLECTION" value:"ns12_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x03" labels:{key:"PCOLLECTION" value:"ns4_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x03" labels:{key:"PCOLLECTION" value:"ns8_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x06u\x08\x1f" labels:{key:"PCOLLECTION" value:"ns8_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\t\x97\x02\x1f\x1f" labels:{key:"PCOLLECTION" value:"ns16_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x03\x18\x08\x08" labels:{key:"PCOLLECTION" value:"ns4_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\t" labels:{key:"PCOLLECTION" value:"ns16_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x02'\x08\x1f" labels:{key:"PCOLLECTION" value:"ns16_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x01\x18\x18\x18" labels:{key:"PCOLLECTION" value:"ns16_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x05(\x08\x08" labels:{key:"PCOLLECTION" value:"ns12_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x03\x18\x08\x08" labels:{key:"PCOLLECTION" value:"ns8_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x01" labels:{key:"PCOLLECTION" value:"ns16_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\n" labels:{key:"PCOLLECTION" value:"ns12_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x03" labels:{key:"PCOLLECTION" value:"ns8_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x06" labels:{key:"PCOLLECTION" value:"ns4_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x03]\x1f\x1f" labels:{key:"PCOLLECTION" value:"ns4_lifted"}] 2023/03/02 17:05:09 INFO Serving Worker components endpoint=[::]:41505 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:41505 for control ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.096Z worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:41505 for logging ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.096Z worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 INFO (): starting job-024[go-job-24-1677776709090483704] source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:104 time=2023-03-02T17:05:09.098Z worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 INFO Job state: STOPPED source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:117 time=2023-03-02T17:05:09.098Z worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 INFO Job state: STARTING source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:117 time=2023-03-02T17:05:09.098Z worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 INFO (): running job-024[go-job-24-1677776709090483704] source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:104 time=2023-03-02T17:05:09.098Z worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 INFO Job state: RUNNING source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:117 time=2023-03-02T17:05:09.098Z worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:41505 for data ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.107Z worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:41505 for state ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.128Z worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 INFO no more pending elements: terminating pipeline 2023/03/02 17:05:09 INFO pipeline done! job=job-024[go-job-24-1677776709090483704] 2023/03/02 17:05:09 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:41505 2023/03/02 17:05:09 forcing DataChannel[[::]:41505] reconnection on port {[::]:41505} due to rpc error: code = Unavailable desc = error reading from server: EOF 2023/03/02 17:05:09 INFO environment stopped envID=worker[go] job=job-024[go-job-24-1677776709090483704] 2023/03/02 17:05:09 Warning: 10 errors during metrics processing: [failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x02" labels:{key:"PCOLLECTION" value:"ne2_pwr"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x023\x13 " labels:{key:"PCOLLECTION" value:"ne2_pwr"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x08\x8c\x02\x1b(" labels:{key:"PCOLLECTION" value:"ne2_splitnsized"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x02" labels:{key:"PCOLLECTION" value:"ns3_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x01\x04\x04\x04" labels:{key:"PCOLLECTION" value:"ns3_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x01" labels:{key:"PCOLLECTION" value:"ns3_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x08" labels:{key:"PCOLLECTION" value:"ne2_splitnsized"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x01\x11\x11\x11" labels:{key:"PCOLLECTION" value:"ns3_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x01" labels:{key:"PCOLLECTION" value:"ns3_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x02\x15\x04\x11" labels:{key:"PCOLLECTION" value:"ns3_merged"}] 2023/03/02 17:05:09 INFO Serving Worker components endpoint=[::]:35191 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:35191 for control ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.146Z worker.ID=go worker.endpoint=[::]:35191 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:35191 for logging ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.146Z worker.ID=go worker.endpoint=[::]:35191 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:35191 for data ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.155Z worker.ID=go worker.endpoint=[::]:35191 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:35191 for state ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.161Z worker.ID=go worker.endpoint=[::]:35191 2023/03/02 17:05:09 INFO no more pending elements: terminating pipeline 2023/03/02 17:05:09 INFO pipeline done! job=job-025[go-job-25-1677776709140614894] 2023/03/02 17:05:09 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:35191 2023/03/02 17:05:09 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:35191 2023/03/02 17:05:09 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:35191 2023/03/02 17:05:09 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:35191 2023/03/02 17:05:09 INFO environment stopped envID=worker[go] job=job-025[go-job-25-1677776709140614894] 2023/03/02 17:05:09 INFO Serving JobManagement endpoint=[::]:45529 2023/03/02 17:05:09 INFO Serving Worker components endpoint=[::]:40687 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:40687 for control ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.172Z worker.ID=go worker.endpoint=[::]:40687 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:40687 for logging ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.172Z worker.ID=go worker.endpoint=[::]:40687 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:40687 for data ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.174Z worker.ID=go worker.endpoint=[::]:40687 2023/03/02 17:05:09 INFO no more pending elements: terminating pipeline 2023/03/02 17:05:09 INFO pipeline done! job=job-001[go-job-26-1677776709167562426] 2023/03/02 17:05:09 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40687 2023/03/02 17:05:09 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40687 2023/03/02 17:05:09 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:40687 2023/03/02 17:05:09 INFO environment stopped envID=worker[go] job=job-001[go-job-26-1677776709167562426] 2023/03/02 17:05:09 INFO Serving JobManagement endpoint=[::]:33751 2023/03/02 17:05:09 INFO Serving Worker components endpoint=[::]:36751 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:36751 for control ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.218Z worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:36751 for logging ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.218Z worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 INFO (): starting job-001[go-job-27-1677776709182651302] source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:104 time=2023-03-02T17:05:09.220Z worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 INFO Job state: STOPPED source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:117 time=2023-03-02T17:05:09.220Z worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 INFO Job state: STARTING source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:117 time=2023-03-02T17:05:09.220Z worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 INFO (): running job-001[go-job-27-1677776709182651302] source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:104 time=2023-03-02T17:05:09.220Z worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 INFO Job state: RUNNING source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:117 time=2023-03-02T17:05:09.220Z worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:36751 for data ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.220Z worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:36751 for state ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.238Z worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 INFO no more pending elements: terminating pipeline 2023/03/02 17:05:09 INFO pipeline done! job=job-001[go-job-27-1677776709182651302] 2023/03/02 17:05:09 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:36751 2023/03/02 17:05:09 (): pipeline completed job-001[go-job-27-1677776709182651302] 2023/03/02 17:05:09 Warning: 10 errors during metrics processing: [failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x01\x04\x04\x04" labels:{key:"PCOLLECTION" value:"ns3_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x01\x11\x11\x11" labels:{key:"PCOLLECTION" value:"ns3_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x01" labels:{key:"PCOLLECTION" value:"ns3_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x01" labels:{key:"PCOLLECTION" value:"ns3_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x02" labels:{key:"PCOLLECTION" value:"ne2_pwr"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x023\x13 " labels:{key:"PCOLLECTION" value:"ne2_pwr"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x06\xbc\x01\x1b(" labels:{key:"PCOLLECTION" value:"ne2_splitnsized"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x02" labels:{key:"PCOLLECTION" value:"ns3_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x02\x15\x04\x11" labels:{key:"PCOLLECTION" value:"ns3_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x06" labels:{key:"PCOLLECTION" value:"ne2_splitnsized"}] 2023/03/02 17:05:09 INFO environment stopped envID=worker[go] job=job-001[go-job-27-1677776709182651302] 2023/03/02 17:05:09 INFO Serving Worker components endpoint=[::]:34577 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:34577 for control ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.261Z worker.ID=go worker.endpoint=[::]:34577 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:34577 for logging ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.261Z worker.ID=go worker.endpoint=[::]:34577 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:34577 for data ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.295Z worker.ID=go worker.endpoint=[::]:34577 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:34577 for state ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.315Z worker.ID=go worker.endpoint=[::]:34577 dofn2x1 v 0 c 0 dofn2x1 v 5 c 1 dofn2x1 v 1 c 2 dofn2x1 v 6 c 3 dofn2x1 v 2 c 4 dofn2x1 v 7 c 5 dofn2x1 v 3 c 6 dofn2x1 v 8 c 7 dofn2x1 v 4 c 8 dofn2x1 v 9 c 9 dofn2x1 sum 45 count 10 2023/03/02 17:05:09 INFO no more pending elements: terminating pipeline 2023/03/02 17:05:09 INFO pipeline done! job=job-002[go-job-28-1677776709252634250] 2023/03/02 17:05:09 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:34577 2023/03/02 17:05:09 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:34577 2023/03/02 17:05:09 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:34577 2023/03/02 17:05:09 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:34577 2023/03/02 17:05:09 forcing DataChannel[[::]:34577] reconnection on port {[::]:34577} due to rpc error: code = Unavailable desc = error reading from server: EOF 2023/03/02 17:05:09 INFO environment stopped envID=worker[go] job=job-002[go-job-28-1677776709252634250] 2023/03/02 17:05:09 Warning: 10 errors during metrics processing: [failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x02" labels:{key:"PCOLLECTION" value:"ne2_pwr"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x01\x04\x04\x04" labels:{key:"PCOLLECTION" value:"ns3_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x01" labels:{key:"PCOLLECTION" value:"ns3_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x01\x11\x11\x11" labels:{key:"PCOLLECTION" value:"ns3_lifted"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x02\x15\x04\x11" labels:{key:"PCOLLECTION" value:"ns3_merged"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x0c" labels:{key:"PCOLLECTION" value:"ne2_splitnsized"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x01" labels:{key:"PCOLLECTION" value:"ns3_grouped"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x023\x13 " labels:{key:"PCOLLECTION" value:"ne2_pwr"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x0c\xde\x02\x1b(" labels:{key:"PCOLLECTION" value:"ne2_splitnsized"} failed to deduce Step from MonitoringInfo: urn:"beam:metric:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x02" labels:{key:"PCOLLECTION" value:"ns3_merged"}] 2023/03/02 17:05:09 INFO Serving Worker components endpoint=[::]:43557 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:43557 for control ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.343Z worker.ID=go worker.endpoint=[::]:43557 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:43557 for logging ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.344Z worker.ID=go worker.endpoint=[::]:43557 2023/03/02 17:05:09 INFO Connecting via grpc @ [::]:43557 for data ... source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:703 time=2023-03-02T17:05:09.346Z worker.ID=go worker.endpoint=[::]:43557 2023/03/02 17:05:11 ERROR process bundle failed for instruction inst2257 using plan stage022 : while executing FinishBundle for Plan[stage022]: 2: DataSink[S[e8_i0@[::]:43557]] Coder:W;cwv_n8<varint;c2>!IWC 3: PCollection[n8] Out:[2] 4: ParDo[internal.int64Check] Out:[2] Sig: func(int64, func(int64)) 1: DataSource[S[e8_source@[::]:43557], i0] Out:4 Coder:W;cwv_n7<varint;c2>!IWC caused by: DoFn[UID:4, PID:internal.int64Check, Name: github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal.int64Check] failed: int64Check[single] (-want, +got): []int{ 55, + 55, } source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:477 time=2023-03-02T17:05:11.285Z worker.ID=go worker.endpoint=[::]:43557 2023/03/02 17:05:11 ERROR ctrl.Recv pipeline error err="process bundle failed for instruction inst2257 using plan stage022 : while executing FinishBundle for Plan[stage022]:\n2: DataSink[S[e8_i0@[::]:43557]] Coder:W;cwv_n8<varint;c2>!IWC\n3: PCollection[n8] Out:[2]\n4: ParDo[internal.int64Check] Out:[2] Sig: func(int64, func(int64))\n1: DataSource[S[e8_source@[::]:43557], i0] Out:4 Coder:W;cwv_n7<varint;c2>!IWC \n\tcaused by:\nDoFn[UID:4, PID:internal.int64Check, Name: github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal.int64Check] failed:\nint64Check[single] (-want, +got): []int{\n \t55,\n+ \t55,\n }\n" panic: process bundle failed for instruction inst2257 using plan stage022 : while executing FinishBundle for Plan[stage022]: 2: DataSink[S[e8_i0@[::]:43557]] Coder:W;cwv_n8<varint;c2>!IWC 3: PCollection[n8] Out:[2] 4: ParDo[internal.int64Check] Out:[2] Sig: func(int64, func(int64)) 1: DataSource[S[e8_source@[::]:43557], i0] Out:4 Coder:W;cwv_n7<varint;c2>!IWC caused by: DoFn[UID:4, PID:internal.int64Check, Name: github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal.int64Check] failed: int64Check[single] (-want, +got): []int{ 55, + 55, } goroutine 3899 [running]: github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/worker.(*W).Control.func1() <https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/prism/internal/worker/worker.go>:224 +0x45f created by github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/worker.(*W).Control <https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/prism/internal/worker/worker.go>:198 +0xb8 FAIL github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal 8.606s ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/config (cached) ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/engine 0.055s ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/jobservices 0.063s ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/urns 0.045s ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/worker 0.108s ? github.com/apache/beam/sdks/v2/go/pkg/beam/runners/samza [no test files] ? github.com/apache/beam/sdks/v2/go/pkg/beam/runners/spark [no test files] ? github.com/apache/beam/sdks/v2/go/pkg/beam/runners/universal [no test files] ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/universal/extworker 0.080s ? github.com/apache/beam/sdks/v2/go/pkg/beam/runners/universal/runnerlib [no test files] ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/vet 0.072s ? github.com/apache/beam/sdks/v2/go/pkg/beam/runners/vet/testpipeline [no test files] ok github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert 0.215s ok github.com/apache/beam/sdks/v2/go/pkg/beam/testing/ptest 0.081s ok github.com/apache/beam/sdks/v2/go/pkg/beam/testing/teststream 0.062s ok github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/filter 0.058s ok github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/sql 0.058s ? github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/sql/sqlx [no test files] ok github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/stats 7.828s ok github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/top 0.120s ? github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/xlang [no test files] ? github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/xlang/dataframe [no test files] ? github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/xlang/inference [no test files] ? github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/xlang/python [no test files] ? github.com/apache/beam/sdks/v2/go/pkg/beam/util/diagnostics [no test files] ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/errorx (cached) ? github.com/apache/beam/sdks/v2/go/pkg/beam/util/execx [no test files] ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/gcsx 0.104s ? github.com/apache/beam/sdks/v2/go/pkg/beam/util/grpcx [no test files] ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/harnessopts 0.103s ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/pubsubx 1.097s ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/shimx (cached) ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/starcgenx 0.071s ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/structx (cached) ? github.com/apache/beam/sdks/v2/go/pkg/beam/util/syscallx [no test files] ? github.com/apache/beam/sdks/v2/go/pkg/beam/x/beamx [no test files] ok github.com/apache/beam/sdks/v2/go/pkg/beam/x/debug 0.103s ? github.com/apache/beam/sdks/v2/go/pkg/beam/x/hooks/perf [no test files] ok github.com/apache/beam/sdks/v2/go/test/integration 0.108s ? github.com/apache/beam/sdks/v2/go/test/integration/driver [no test files] ? github.com/apache/beam/sdks/v2/go/test/integration/internal/containers [no test files] ? github.com/apache/beam/sdks/v2/go/test/integration/internal/jars [no test files] ? github.com/apache/beam/sdks/v2/go/test/integration/internal/ports [no test files] ok github.com/apache/beam/sdks/v2/go/test/integration/io/fhirio 0.141s ok github.com/apache/beam/sdks/v2/go/test/integration/io/mongodbio 50.370s ok github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/bigquery 0.143s ok github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/debezium 0.124s ok github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/jdbc 0.145s ok github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka 0.142s ok github.com/apache/beam/sdks/v2/go/test/integration/primitives 0.260s ok github.com/apache/beam/sdks/v2/go/test/integration/synthetic 0.878s ok github.com/apache/beam/sdks/v2/go/test/integration/transforms/xlang/dataframe 0.078s ok github.com/apache/beam/sdks/v2/go/test/integration/transforms/xlang/inference 0.091s ok github.com/apache/beam/sdks/v2/go/test/integration/wordcount 0.132s ok github.com/apache/beam/sdks/v2/go/test/integration/xlang 10.892s ? github.com/apache/beam/sdks/v2/go/test/load [no test files] ? github.com/apache/beam/sdks/v2/go/test/load/cogbk [no test files] ? github.com/apache/beam/sdks/v2/go/test/load/combine [no test files] ? github.com/apache/beam/sdks/v2/go/test/load/group_by_key [no test files] ? github.com/apache/beam/sdks/v2/go/test/load/pardo [no test files] ? github.com/apache/beam/sdks/v2/go/test/load/sideinput [no test files] ok github.com/apache/beam/sdks/v2/go/test/regression 0.383s ok github.com/apache/beam/sdks/v2/go/test/regression/coders/fromyaml 0.192s FAIL > Task :sdks:go:goTest FAILED > Task :goPrecommitBuild FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':sdks:go:goTest'. > 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. * Get more help at https://help.gradle.org BUILD FAILED in 4m 27s 17 actionable tasks: 11 executed, 4 from cache, 2 up-to-date Publishing build scan... https://gradle.com/s/rmcqtnmjmgxz2 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]
