See <https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/6905/display/redirect>
Changes: ------------------------------------------ [...truncated 68.36 KB...] 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:42425 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-28T16:41:40.573Z worker.ID=go worker.endpoint=[::]:42425 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:42425 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-28T16:41:40.573Z worker.ID=go worker.endpoint=[::]:42425 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:42425 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-28T16:41:40.576Z worker.ID=go worker.endpoint=[::]:42425 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:42425 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-28T16:41:40.618Z worker.ID=go worker.endpoint=[::]:42425 2023/03/28 16:41:40 INFO no more pending elements: terminating pipeline 2023/03/28 16:41:40 INFO pipeline done! job=job-021[go-job-21-1680021700560109135] 2023/03/28 16:41:40 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:42425 2023/03/28 16:41:40 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:42425 2023/03/28 16:41:40 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:42425 2023/03/28 16:41:40 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:42425 2023/03/28 16:41:40 control response channel closed 2023/03/28 16:41:40 INFO environment stopped envID=worker[go] job=job-021[go-job-21-1680021700560109135] 2023/03/28 16:41:40 INFO Serving Worker components endpoint=[::]:41017 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:41017 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-28T16:41:40.696Z worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:41017 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-28T16:41:40.696Z worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:41017 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-28T16:41:40.699Z worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:41017 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-28T16:41:40.728Z worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 INFO no more pending elements: terminating pipeline 2023/03/28 16:41:40 INFO pipeline done! job=job-022[go-job-22-1680021700687710241] 2023/03/28 16:41:40 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 WARN forcing DataChannel[[::]:41017] reconnection on port {[::]:41017} due to EOF source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/datamgr.go>:118 time=2023-03-28T16:41:40.764Z worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 WARN DataChannel.read [::]:41017 closed source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/datamgr.go>:261 time=2023-03-28T16:41:40.764Z worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 INFO (): pipeline completed job-022[go-job-22-1680021700687710241] 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-28T16:41:40.764Z worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 forcing StateChannel[[::]:41017] reconnection on port {[::]:41017} due to rpc error: code = Unavailable desc = error reading from server: EOF 2023/03/28 16:41:40 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:41017 2023/03/28 16:41:40 INFO environment stopped envID=worker[go] job=job-022[go-job-22-1680021700687710241] 2023/03/28 16:41:40 INFO Serving Worker components endpoint=[::]:34479 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:34479 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-28T16:41:40.793Z worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:34479 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-28T16:41:40.793Z worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:34479 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-28T16:41:40.796Z worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:34479 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-28T16:41:40.865Z worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 INFO no more pending elements: terminating pipeline 2023/03/28 16:41:40 INFO pipeline done! job=job-023[go-job-23-1680021700780629630] 2023/03/28 16:41:40 INFO (): pipeline completed job-023[go-job-23-1680021700780629630] 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-28T16:41:40.897Z worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 WARN forcing StateChannel[[::]:34479] reconnection on port {[::]:34479} due to rpc error: code = Unavailable desc = error reading from server: EOF source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/statemgr.go>:528 time=2023-03-28T16:41:40.898Z worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 ERROR StateChannel[[::]:34479].read bad: rpc error: code = Unavailable desc = error reading from server: EOF source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/statemgr.go>:618 time=2023-03-28T16:41:40.898Z worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 WARN forcing DataChannel[[::]:34479] reconnection on port {[::]:34479} due to EOF source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/datamgr.go>:118 time=2023-03-28T16:41:40.898Z worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 WARN DataChannel.read [::]:34479 closed source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/datamgr.go>:261 time=2023-03-28T16:41:40.898Z worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:34479 2023/03/28 16:41:40 control response channel closed 2023/03/28 16:41:40 INFO environment stopped envID=worker[go] job=job-023[go-job-23-1680021700780629630] 2023/03/28 16:41:40 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:"\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:"\x03]\x1f\x1f" labels:{key:"PCOLLECTION" value:"ns8_lifted"} 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:"\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:"\x03]\x1f\x1f" 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:"\n" labels:{key:"PCOLLECTION" value:"ns12_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:"\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:"ns4_grouped"} 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:"\x03" labels:{key:"PCOLLECTION" value:"ns4_grouped"} 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\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:"\x01" 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:"\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:"\x06" labels:{key:"PCOLLECTION" value:"ns4_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: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: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: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: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: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:element_count:v1" type:"beam:metrics:sum_int64:v1" payload:"\x03" labels:{key:"PCOLLECTION" value:"ns8_lifted"}] 2023/03/28 16:41:40 INFO Serving Worker components endpoint=[::]:44995 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:44995 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-28T16:41:40.917Z worker.ID=go worker.endpoint=[::]:44995 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:44995 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-28T16:41:40.917Z worker.ID=go worker.endpoint=[::]:44995 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:44995 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-28T16:41:40.921Z worker.ID=go worker.endpoint=[::]:44995 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:44995 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-28T16:41:40.928Z worker.ID=go worker.endpoint=[::]:44995 2023/03/28 16:41:40 INFO no more pending elements: terminating pipeline 2023/03/28 16:41:40 INFO pipeline done! job=job-024[go-job-24-1680021700904959460] 2023/03/28 16:41:40 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44995 2023/03/28 16:41:40 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44995 2023/03/28 16:41:40 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44995 2023/03/28 16:41:40 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44995 2023/03/28 16:41:40 stopping worker go 2023/03/28 16:41:40 INFO environment stopped envID=worker[go] job=job-024[go-job-24-1680021700904959460] 2023/03/28 16:41:40 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:"\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:"\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:"\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:"\x08" 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: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: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:"\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:"\x023\x13 " labels:{key:"PCOLLECTION" value:"ne2_pwr"}] 2023/03/28 16:41:40 INFO Serving Worker components endpoint=[::]:38073 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:38073 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-28T16:41:40.957Z worker.ID=go worker.endpoint=[::]:38073 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:38073 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-28T16:41:40.957Z worker.ID=go worker.endpoint=[::]:38073 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:38073 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-28T16:41:40.959Z worker.ID=go worker.endpoint=[::]:38073 2023/03/28 16:41:40 INFO Connecting via grpc @ [::]:38073 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-28T16:41:40.964Z worker.ID=go worker.endpoint=[::]:38073 2023/03/28 16:41:40 INFO no more pending elements: terminating pipeline 2023/03/28 16:41:40 INFO pipeline done! job=job-025[go-job-25-1680021700947679479] 2023/03/28 16:41:40 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:38073 2023/03/28 16:41:40 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:38073 2023/03/28 16:41:40 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:38073 2023/03/28 16:41:40 (): pipeline completed job-025[go-job-25-1680021700947679479] 2023/03/28 16:41:40 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:38073 2023/03/28 16:41:40 INFO environment stopped envID=worker[go] job=job-025[go-job-25-1680021700947679479] 2023/03/28 16:41:40 INFO Serving JobManagement endpoint=[::]:45981 2023/03/28 16:41:40 INFO Serving Worker components endpoint=[::]:44635 2023/03/28 16:41:40 INFO no more pending elements: terminating pipeline 2023/03/28 16:41:40 INFO pipeline done! job=job-001[go-job-26-1680021700976176757] 2023/03/28 16:41:40 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44635 2023/03/28 16:41:40 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:44635 2023/03/28 16:41:40 (): pipeline completed job-001[go-job-26-1680021700976176757] 2023/03/28 16:41:40 INFO environment stopped envID=worker[go] job=job-001[go-job-26-1680021700976176757] 2023/03/28 16:41:40 INFO Serving JobManagement endpoint=[::]:42395 2023/03/28 16:41:41 INFO Serving Worker components endpoint=[::]:39739 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:39739 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-28T16:41:41.004Z worker.ID=go worker.endpoint=[::]:39739 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:39739 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-28T16:41:41.004Z worker.ID=go worker.endpoint=[::]:39739 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:39739 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-28T16:41:41.010Z worker.ID=go worker.endpoint=[::]:39739 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:39739 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-28T16:41:41.021Z worker.ID=go worker.endpoint=[::]:39739 2023/03/28 16:41:41 INFO no more pending elements: terminating pipeline 2023/03/28 16:41:41 INFO pipeline done! job=job-001[go-job-27-1680021700991567822] 2023/03/28 16:41:41 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:39739 2023/03/28 16:41:41 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:39739 2023/03/28 16:41:41 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:39739 2023/03/28 16:41:41 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:39739 2023/03/28 16:41:41 control response channel closed 2023/03/28 16:41:41 INFO environment stopped envID=worker[go] job=job-001[go-job-27-1680021700991567822] 2023/03/28 16:41:41 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:"ns3_merged"} 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"} 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:"\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:"\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:"\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:"\x06" 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:"\x02" labels:{key:"PCOLLECTION" value:"ne2_pwr"}] 2023/03/28 16:41:41 INFO Serving Worker components endpoint=[::]:37283 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:37283 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-28T16:41:41.052Z worker.ID=go worker.endpoint=[::]:37283 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:37283 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-28T16:41:41.052Z worker.ID=go worker.endpoint=[::]:37283 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:37283 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-28T16:41:41.056Z worker.ID=go worker.endpoint=[::]:37283 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:37283 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-28T16:41:41.070Z worker.ID=go worker.endpoint=[::]:37283 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/28 16:41:41 INFO no more pending elements: terminating pipeline 2023/03/28 16:41:41 INFO pipeline done! job=job-002[go-job-28-1680021701041036925] 2023/03/28 16:41:41 control response channel closed 2023/03/28 16:41:41 ERROR logging.Recv err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:37283 2023/03/28 16:41:41 ERROR data.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:37283 2023/03/28 16:41:41 ERROR state.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:37283 2023/03/28 16:41:41 ERROR ctrl.Recv Canceled err="rpc error: code = Canceled desc = context canceled" worker.ID=go worker.endpoint=[::]:37283 2023/03/28 16:41:41 INFO environment stopped envID=worker[go] job=job-002[go-job-28-1680021701041036925] 2023/03/28 16:41:41 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:"\x0c\xde\x02\x1b(" 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:"\x023\x13 " labels:{key:"PCOLLECTION" value:"ne2_pwr"} 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: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:"\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_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:"\x02" 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:sampled_byte_size:v1" type:"beam:metrics:distribution_int64:v1" payload:"\x01\x04\x04\x04" labels:{key:"PCOLLECTION" value:"ns3_grouped"}] 2023/03/28 16:41:41 INFO Serving Worker components endpoint=[::]:44891 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:44891 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-28T16:41:41.114Z worker.ID=go worker.endpoint=[::]:44891 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:44891 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-28T16:41:41.114Z worker.ID=go worker.endpoint=[::]:44891 2023/03/28 16:41:41 INFO Connecting via grpc @ [::]:44891 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-28T16:41:41.120Z worker.ID=go worker.endpoint=[::]:44891 2023/03/28 16:41:43 ERROR process bundle failed for instruction inst2582 using plan stage022 : while executing FinishBundle for Plan[stage022]: 2: DataSink[S[e8_i0@[::]:44891]] 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@[::]:44891], 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-28T16:41:43.252Z worker.ID=go worker.endpoint=[::]:44891 2023/03/28 16:41:43 ERROR ctrl.Recv pipeline error err="process bundle failed for instruction inst2582 using plan stage022 : while executing FinishBundle for Plan[stage022]:\n2: DataSink[S[e8_i0@[::]:44891]] 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@[::]:44891], 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 inst2582 using plan stage022 : while executing FinishBundle for Plan[stage022]: 2: DataSink[S[e8_i0@[::]:44891]] 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@[::]:44891], 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 3845 [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 4.731s ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/config 0.031s ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/engine 0.057s 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.124s ok github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/worker 0.051s ? 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.083s ? 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.115s ? 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.158s ok github.com/apache/beam/sdks/v2/go/pkg/beam/testing/ptest 0.069s ok github.com/apache/beam/sdks/v2/go/pkg/beam/testing/teststream 0.047s ok github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/filter 0.104s ok github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/periodic 17.208s ok github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/sql 0.061s ? 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 5.578s ok github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/top 0.061s ? 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 0.063s ? 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/fsx 0.056s ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/gcsx 0.122s ? 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.083s ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/pubsubx 1.143s ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/shimx 0.060s ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/starcgenx 0.085s ok github.com/apache/beam/sdks/v2/go/pkg/beam/util/structx 0.076s ? 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.065s ? 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.155s ? 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/bigqueryio 0.110s ok github.com/apache/beam/sdks/v2/go/test/integration/io/fhirio 0.130s ok github.com/apache/beam/sdks/v2/go/test/integration/io/mongodbio 38.978s ok github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/bigquery 0.135s ok github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/debezium 0.088s ok github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/jdbc 0.172s ok github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka 0.081s ok github.com/apache/beam/sdks/v2/go/test/integration/primitives 0.145s ok github.com/apache/beam/sdks/v2/go/test/integration/synthetic 0.447s ok github.com/apache/beam/sdks/v2/go/test/integration/transforms/xlang/dataframe 0.080s ok github.com/apache/beam/sdks/v2/go/test/integration/transforms/xlang/inference 0.119s ok github.com/apache/beam/sdks/v2/go/test/integration/wordcount 0.123s ok github.com/apache/beam/sdks/v2/go/test/integration/xlang 9.350s ? 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.187s ok github.com/apache/beam/sdks/v2/go/test/regression/coders/fromyaml 0.049s 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 43s 17 actionable tasks: 11 executed, 4 from cache, 2 up-to-date Publishing build scan... https://gradle.com/s/lycidrwqoukqu 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]
