See 
<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/7558/display/redirect>

Changes:


------------------------------------------
[...truncated 142.92 KB...]
2: ParDo[passert.boundsFn] Out:[] Sig: func([]uint8, func(*typex.T) bool) 
error, SideInputs: [SideInputAdapter[S[e4@localhost:42239], i1] - Coder 
W<int[varintz;c2];c3>!GWC]
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.AllWithinBounds([0.5, 2.5])/passert.boundsFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.boundsFn] failed:
values below minimum value 0.5: [-1 0] 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:109
 time=2023-09-07T22:18:51.957Z 
worker.ID=job-044[go-job-44-1694125131948416903]_go 
worker.endpoint=localhost:42239
2023/09/07 22:18:51 INFO stopping worker 
job-044[go-job-44-1694125131948416903]_go 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/extworker/extworker.go>:117
 time=2023-09-07T22:18:51.957Z 
worker.ID=job-044[go-job-44-1694125131948416903]_go 
worker.endpoint=localhost:42239
2023/09/07 22:18:51 ERROR process bundle failed for instruction inst003 using 
plan stage007 : while executing Process for Plan[stage007]:
1: DataSource[S[stage007_source@localhost:36423], i0] Out:2 
Coder:W;cwv_n3<bytes;c0>!GWC 
2: ParDo[passert.nonEmptyFn] Out:[] Sig: func([]uint8, func(*typex.Z) bool) 
error, SideInputs: [SideInputAdapter[S[e4@localhost:36423], i1] - Coder 
W<string;c2>!GWC]
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.Hash(empty 
collection)/passert.NonEmpty/passert.nonEmptyFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.nonEmptyFn] failed:
PCollection is empty, want non-empty collection 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:484
 time=2023-09-07T22:18:51.970Z 
worker.ID=job-045[go-job-45-1694125131959532361]_go 
worker.endpoint=localhost:36423
2023/09/07 22:18:51 ERROR job failed job.key=job-045 
job.name=go-job-45-1694125131959532361 error="bundle inst003 failed:process 
bundle failed for instruction inst003 using plan stage007 : while executing 
Process for Plan[stage007]:\n1: DataSource[S[stage007_source@localhost:36423], 
i0] Out:2 Coder:W;cwv_n3<bytes;c0>!GWC \n2: ParDo[passert.nonEmptyFn] Out:[] 
Sig: func([]uint8, func(*typex.Z) bool) error, SideInputs: 
[SideInputAdapter[S[e4@localhost:36423], i1] - Coder 
W<string;c2>!GWC]\n\tcaused by:\nsource failed\n\tcaused by:\nDoFn[UID:2, 
PID:passert.Hash(empty collection)/passert.NonEmpty/passert.nonEmptyFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.nonEmptyFn] 
failed:\nPCollection is empty, want non-empty collection"
2023/09/07 22:18:51 INFO Job[job-045] state: FAILED 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:126
 time=2023-09-07T22:18:51.971Z 
worker.ID=job-045[go-job-45-1694125131959532361]_go 
worker.endpoint=localhost:36423
2023/09/07 22:18:51 INFO stopping worker 
job-045[go-job-45-1694125131959532361]_go 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/extworker/extworker.go>:117
 time=2023-09-07T22:18:51.971Z 
worker.ID=job-045[go-job-45-1694125131959532361]_go 
worker.endpoint=localhost:36423
2023/09/07 22:18:51 ERROR  (): bundle inst003 failed:process bundle failed for 
instruction inst003 using plan stage007 : while executing Process for 
Plan[stage007]:
1: DataSource[S[stage007_source@localhost:36423], i0] Out:2 
Coder:W;cwv_n3<bytes;c0>!GWC 
2: ParDo[passert.nonEmptyFn] Out:[] Sig: func([]uint8, func(*typex.Z) bool) 
error, SideInputs: [SideInputAdapter[S[e4@localhost:36423], i1] - Coder 
W<string;c2>!GWC]
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.Hash(empty 
collection)/passert.NonEmpty/passert.nonEmptyFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.nonEmptyFn] failed:
PCollection is empty, want non-empty collection 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:109
 time=2023-09-07T22:18:51.971Z 
worker.ID=job-045[go-job-45-1694125131959532361]_go 
worker.endpoint=localhost:36423
2023/09/07 22:18:51  (): pipeline completed 
job-046[go-job-46-1694125131972856940]
2023/09/07 22:18:52 control response channel closed
2023/09/07 22:18:52 forcing DataChannel[localhost:41759] reconnection on port 
{localhost:41759} due to EOF
2023/09/07 22:18:52 ERROR job failed job.key=job-048 
job.name=go-job-48-1694125132002311433 error="bundle inst005 failed:process 
bundle failed for instruction inst005 using plan stage004 : while executing 
Process for Plan[stage004]:\n1: DataSource[S[stage004_source@localhost:35789], 
i0] Out:2 Coder:W;cwv_n3<string;c2>!GWC \n2: ParDo[passert.failFn] Out:[] Sig: 
func(typex.X) error, SideInputs: []\n\tcaused by:\nsource failed\n\tcaused 
by:\nDoFn[UID:2, PID:passert.failFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failFn] 
failed:\npredicate(b) = false, want true"
2023/09/07 22:18:52 ERROR process bundle failed for instruction inst005 using 
plan stage004 : while executing Process for Plan[stage004]:
1: DataSource[S[stage004_source@localhost:35789], i0] Out:2 
Coder:W;cwv_n3<string;c2>!GWC 
2: ParDo[passert.failFn] Out:[] Sig: func(typex.X) error, SideInputs: []
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.failFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failFn] failed:
predicate(b) = false, want true 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:484
 time=2023-09-07T22:18:52.015Z 
worker.ID=job-048[go-job-48-1694125132002311433]_go 
worker.endpoint=localhost:35789
2023/09/07 22:18:52 INFO Job[job-048] state: FAILED 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:126
 time=2023-09-07T22:18:52.016Z 
worker.ID=job-048[go-job-48-1694125132002311433]_go 
worker.endpoint=localhost:35789
2023/09/07 22:18:52 INFO stopping worker 
job-048[go-job-48-1694125132002311433]_go 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/extworker/extworker.go>:117
 time=2023-09-07T22:18:52.016Z 
worker.ID=job-048[go-job-48-1694125132002311433]_go 
worker.endpoint=localhost:35789
2023/09/07 22:18:52 ERROR  (): bundle inst005 failed:process bundle failed for 
instruction inst005 using plan stage004 : while executing Process for 
Plan[stage004]:
1: DataSource[S[stage004_source@localhost:35789], i0] Out:2 
Coder:W;cwv_n3<string;c2>!GWC 
2: ParDo[passert.failFn] Out:[] Sig: func(typex.X) error, SideInputs: []
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.failFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failFn] failed:
predicate(b) = false, want true 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:109
 time=2023-09-07T22:18:52.016Z 
worker.ID=job-048[go-job-48-1694125132002311433]_go 
worker.endpoint=localhost:35789
2023/09/07 22:18:52 forcing DataChannel[localhost:32809] reconnection on port 
{localhost:32809} due to EOF
2023/09/07 22:18:52  (): pipeline completed 
job-050[go-job-50-1694125132028342551]
2023/09/07 22:18:52 ERROR process bundle failed for instruction inst005 using 
plan stage004 : while executing Process for Plan[stage004]:
1: DataSource[S[stage004_source@localhost:44665], i0] Out:2 
Coder:W;cwv_n3<string;c2>!GWC 
2: ParDo[passert.failFn] Out:[] Sig: func(typex.X) error, SideInputs: []
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.failFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failFn] failed:
predicate(b) = true, want false 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:484
 time=2023-09-07T22:18:52.057Z 
worker.ID=job-051[go-job-51-1694125132043265111]_go 
worker.endpoint=localhost:44665
2023/09/07 22:18:52 ERROR job failed job.key=job-051 
job.name=go-job-51-1694125132043265111 error="bundle inst005 failed:process 
bundle failed for instruction inst005 using plan stage004 : while executing 
Process for Plan[stage004]:\n1: DataSource[S[stage004_source@localhost:44665], 
i0] Out:2 Coder:W;cwv_n3<string;c2>!GWC \n2: ParDo[passert.failFn] Out:[] Sig: 
func(typex.X) error, SideInputs: []\n\tcaused by:\nsource failed\n\tcaused 
by:\nDoFn[UID:2, PID:passert.failFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failFn] 
failed:\npredicate(b) = true, want false"
2023/09/07 22:18:52 INFO stopping worker 
job-051[go-job-51-1694125132043265111]_go 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/extworker/extworker.go>:117
 time=2023-09-07T22:18:52.058Z 
worker.ID=job-051[go-job-51-1694125132043265111]_go 
worker.endpoint=localhost:44665
2023/09/07 22:18:52 INFO Job[job-051] state: FAILED 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:126
 time=2023-09-07T22:18:52.058Z 
worker.ID=job-051[go-job-51-1694125132043265111]_go 
worker.endpoint=localhost:44665
2023/09/07 22:18:52 INFO  (): pipeline completed 
job-052[go-job-52-1694125132059705886] 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:109
 time=2023-09-07T22:18:52.072Z 
worker.ID=job-052[go-job-52-1694125132059705886]_go 
worker.endpoint=localhost:46195
2023/09/07 22:18:52 WARN forcing DataChannel[localhost:46195] reconnection on 
port {localhost:46195} 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/datamgr.go>:137
 time=2023-09-07T22:18:52.073Z 
worker.ID=job-052[go-job-52-1694125132059705886]_go 
worker.endpoint=localhost:46195
2023/09/07 22:18:52 ERROR DataChannel.read localhost:46195 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/datamgr.go>:385
 time=2023-09-07T22:18:52.073Z 
worker.ID=job-052[go-job-52-1694125132059705886]_go 
worker.endpoint=localhost:46195
2023/09/07 22:18:52 stopping worker job-052[go-job-52-1694125132059705886]_go
2023/09/07 22:18:52 ERROR process bundle failed for instruction inst003 using 
plan stage003 : while executing Process for Plan[stage003]:
1: DataSource[S[stage003_source@localhost:39641], i0] Out:2 
Coder:W;cwv_n2<string;c2>!GWC 
2: ParDo[passert.failFn] Out:[] Sig: func(typex.X) error, SideInputs: []
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.failFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failFn] failed:
PCollection contains a, want empty collection 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:484
 time=2023-09-07T22:18:52.086Z 
worker.ID=job-053[go-job-53-1694125132075976251]_go 
worker.endpoint=localhost:39641
2023/09/07 22:18:52 ERROR job failed job.key=job-053 
job.name=go-job-53-1694125132075976251 error="bundle inst003 failed:process 
bundle failed for instruction inst003 using plan stage003 : while executing 
Process for Plan[stage003]:\n1: DataSource[S[stage003_source@localhost:39641], 
i0] Out:2 Coder:W;cwv_n2<string;c2>!GWC \n2: ParDo[passert.failFn] Out:[] Sig: 
func(typex.X) error, SideInputs: []\n\tcaused by:\nsource failed\n\tcaused 
by:\nDoFn[UID:2, PID:passert.failFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failFn] 
failed:\nPCollection contains a, want empty collection"
2023/09/07 22:18:52 INFO Job[job-053] state: FAILED 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:126
 time=2023-09-07T22:18:52.087Z 
worker.ID=job-053[go-job-53-1694125132075976251]_go 
worker.endpoint=localhost:39641
2023/09/07 22:18:52 ERROR  (): bundle inst003 failed:process bundle failed for 
instruction inst003 using plan stage003 : while executing Process for 
Plan[stage003]:
1: DataSource[S[stage003_source@localhost:39641], i0] Out:2 
Coder:W;cwv_n2<string;c2>!GWC 
2: ParDo[passert.failFn] Out:[] Sig: func(typex.X) error, SideInputs: []
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.failFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failFn] failed:
PCollection contains a, want empty collection 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:109
 time=2023-09-07T22:18:52.087Z 
worker.ID=job-053[go-job-53-1694125132075976251]_go 
worker.endpoint=localhost:39641
2023/09/07 22:18:52 INFO stopping worker 
job-053[go-job-53-1694125132075976251]_go 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/extworker/extworker.go>:117
 time=2023-09-07T22:18:52.087Z 
worker.ID=job-053[go-job-53-1694125132075976251]_go 
worker.endpoint=localhost:39641
2023/09/07 22:18:52  (): pipeline completed 
job-054[go-job-54-1694125132088459467]
2023/09/07 22:18:52  (): terminating job-054[go-job-54-1694125132088459467]
2023/09/07 22:18:52 Job[job-054] state: DONE
2023/09/07 22:18:52 forcing StateChannel[localhost:38241] reconnection on port 
{localhost:38241} due to rpc error: code = Unavailable desc = error reading 
from server: EOF
2023/09/07 22:18:52 ERROR process bundle failed for instruction inst003 using 
plan stage004 : while executing Process for Plan[stage004]:
1: DataSource[S[stage004_source@localhost:34579], i0] Out:2 
Coder:W;cwv_n3<bytes;c0>!GWC 
2: ParDo[passert.nonEmptyFn] Out:[] Sig: func([]uint8, func(*typex.Z) bool) 
error, SideInputs: [SideInputAdapter[S[e4@localhost:34579], i1] - Coder 
W<string;c2>!GWC]
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.NonEmpty/passert.nonEmptyFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.nonEmptyFn] failed:
PCollection is empty, want non-empty collection 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:484
 time=2023-09-07T22:18:52.135Z 
worker.ID=job-055[go-job-55-1694125132123374319]_go 
worker.endpoint=localhost:34579
2023/09/07 22:18:52 ERROR job failed job.key=job-055 
job.name=go-job-55-1694125132123374319 error="bundle inst003 failed:process 
bundle failed for instruction inst003 using plan stage004 : while executing 
Process for Plan[stage004]:\n1: DataSource[S[stage004_source@localhost:34579], 
i0] Out:2 Coder:W;cwv_n3<bytes;c0>!GWC \n2: ParDo[passert.nonEmptyFn] Out:[] 
Sig: func([]uint8, func(*typex.Z) bool) error, SideInputs: 
[SideInputAdapter[S[e4@localhost:34579], i1] - Coder 
W<string;c2>!GWC]\n\tcaused by:\nsource failed\n\tcaused by:\nDoFn[UID:2, 
PID:passert.NonEmpty/passert.nonEmptyFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.nonEmptyFn] 
failed:\nPCollection is empty, want non-empty collection"
2023/09/07 22:18:52 INFO Job[job-055] state: FAILED 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:126
 time=2023-09-07T22:18:52.136Z 
worker.ID=job-055[go-job-55-1694125132123374319]_go 
worker.endpoint=localhost:34579
2023/09/07 22:18:52 ERROR  (): bundle inst003 failed:process bundle failed for 
instruction inst003 using plan stage004 : while executing Process for 
Plan[stage004]:
1: DataSource[S[stage004_source@localhost:34579], i0] Out:2 
Coder:W;cwv_n3<bytes;c0>!GWC 
2: ParDo[passert.nonEmptyFn] Out:[] Sig: func([]uint8, func(*typex.Z) bool) 
error, SideInputs: [SideInputAdapter[S[e4@localhost:34579], i1] - Coder 
W<string;c2>!GWC]
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.NonEmpty/passert.nonEmptyFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.nonEmptyFn] failed:
PCollection is empty, want non-empty collection 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:109
 time=2023-09-07T22:18:52.136Z 
worker.ID=job-055[go-job-55-1694125132123374319]_go 
worker.endpoint=localhost:34579
2023/09/07 22:18:52 INFO stopping worker 
job-055[go-job-55-1694125132123374319]_go 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/extworker/extworker.go>:117
 time=2023-09-07T22:18:52.136Z 
worker.ID=job-055[go-job-55-1694125132123374319]_go 
worker.endpoint=localhost:34579
2023/09/07 22:18:52 forcing DataChannel[localhost:41781] reconnection on port 
{localhost:41781} due to rpc error: code = Unavailable desc = error reading 
from server: EOF
2023/09/07 22:18:52 DataChannel.read localhost:41781 bad: rpc error: code = 
Unavailable desc = error reading from server: EOF
2023/09/07 22:18:52  (): pipeline completed 
job-057[go-job-57-1694125132160128341]
2023/09/07 22:18:52 stopping worker job-057[go-job-57-1694125132160128341]_go
2023/09/07 22:18:52  (): terminating job-057[go-job-57-1694125132160128341]
2023/09/07 22:18:52 Job[job-057] state: DONE
2023/09/07 22:18:52 forcing StateChannel[localhost:32897] reconnection on port 
{localhost:32897} due to rpc error: code = Unavailable desc = error reading 
from server: EOF
2023/09/07 22:18:52 control response channel closed
2023/09/07 22:18:52 forcing StateChannel[localhost:41007] reconnection on port 
{localhost:41007} due to rpc error: code = Unavailable desc = error reading 
from server: EOF
2023/09/07 22:18:52 control response channel closed
2023/09/07 22:18:52 ERROR process bundle failed for instruction inst007 using 
plan stage006 : while executing Process for Plan[stage006]:
1: DataSource[S[stage006_source@localhost:41869], i0] Out:2 
Coder:W<CoGBK<int[varintz;c2];c3,int[varintz;c2];c3>>!GWC 
2: ParDo[passert.sumFn] Out:[] Sig: func(int, func(*int) bool) error, 
SideInputs: []
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.Sum(bad size)/passert.sumFn, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.sumFn] failed:
passert.Sum(bad size) = {15, size: 5}, want {15, size:4} 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:484
 time=2023-09-07T22:18:52.247Z 
worker.ID=job-060[go-job-60-1694125132212689884]_go 
worker.endpoint=localhost:41869
2023/09/07 22:18:52  (): pipeline completed 
job-060[go-job-60-1694125132212689884]
--- FAIL: TestSum_bad (0.04s)
    sum_test.go:104: Pipeline succeeded but should have failed: bad size
2023/09/07 22:18:52 INFO  (): pipeline completed 
job-061[go-job-61-1694125132251717404] 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/execute.go>:109
 time=2023-09-07T22:18:52.265Z 
worker.ID=job-061[go-job-61-1694125132251717404]_go 
worker.endpoint=localhost:37169
2023/09/07 22:18:52 WARN forcing DataChannel[localhost:37169] reconnection on 
port {localhost:37169} 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>:137
 time=2023-09-07T22:18:52.265Z 
worker.ID=job-061[go-job-61-1694125132251717404]_go 
worker.endpoint=localhost:37169
2023/09/07 22:18:52 stopping worker job-061[go-job-61-1694125132251717404]_go
2023/09/07 22:18:52 forcing StateChannel[localhost:37169] reconnection on port 
{localhost:37169} due to rpc error: code = Unavailable desc = error reading 
from server: EOF
2023/09/07 22:18:52  (): pipeline completed 
job-062[go-job-62-1694125132321013810]
2023/09/07 22:18:52 stopping worker job-062[go-job-62-1694125132321013810]_go
2023/09/07 22:18:52  (): terminating job-062[go-job-62-1694125132321013810]
2023/09/07 22:18:52 Job[job-062] state: DONE
2023/09/07 22:18:52 control response channel closed
2023/09/07 22:18:52 stopping worker job-063[go-job-63-1694125132344522961]_go
2023/09/07 22:18:52  (): pipeline completed 
job-063[go-job-63-1694125132344522961]
2023/09/07 22:18:52  (): terminating job-063[go-job-63-1694125132344522961]
2023/09/07 22:18:52 ERROR process bundle failed for instruction inst007 using 
plan stage008 : while executing Process for Plan[stage008]:
1: DataSource[S[stage008_source@localhost:39965], i0] Out:2 
Coder:W;cwv_n9<bytes;c0>!GWC 
2: ParDo[passert.failIfBadEntries] Out:[] Sig: func([]uint8, func(*typex.T) 
bool, func(*typex.T) bool, func(*typex.T) bool) error, SideInputs: 
[SideInputAdapter[S[e8@localhost:39965], i1] - Coder W<string;c2>!GWC 
SideInputAdapter[S[e8@localhost:39965], i2] - Coder W<string;c2>!GWC 
SideInputAdapter[S[e8@localhost:39965], i3] - Coder W<string;c2>!GWC]
        caused by:
source failed
        caused by:
DoFn[UID:2, PID:passert.EqualsList/passert.failIfBadEntries, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failIfBadEntries] 
failed:
actual PCollection does not match expected values
=========
2 correct entries (present in both)
=========
1 unexpected entries (present in actual, missing in expected)
+++
example
=========
1 missing entries (missing in actual, present in expected)
---
wrong 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:484
 time=2023-09-07T22:18:52.378Z 
worker.ID=job-064[go-job-64-1694125132362993572]_go 
worker.endpoint=localhost:39965
2023/09/07 22:18:52 ERROR job failed job.key=job-064 
job.name=go-job-64-1694125132362993572 error="bundle inst007 failed:process 
bundle failed for instruction inst007 using plan stage008 : while executing 
Process for Plan[stage008]:\n1: DataSource[S[stage008_source@localhost:39965], 
i0] Out:2 Coder:W;cwv_n9<bytes;c0>!GWC \n2: ParDo[passert.failIfBadEntries] 
Out:[] Sig: func([]uint8, func(*typex.T) bool, func(*typex.T) bool, 
func(*typex.T) bool) error, SideInputs: 
[SideInputAdapter[S[e8@localhost:39965], i1] - Coder W<string;c2>!GWC 
SideInputAdapter[S[e8@localhost:39965], i2] - Coder W<string;c2>!GWC 
SideInputAdapter[S[e8@localhost:39965], i3] - Coder W<string;c2>!GWC]\n\tcaused 
by:\nsource failed\n\tcaused by:\nDoFn[UID:2, 
PID:passert.EqualsList/passert.failIfBadEntries, Name: 
github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert.failIfBadEntries] 
failed:\nactual PCollection does not match expected values\n=========\n2 
correct entries (present in both)\n=========\n1 unexpected entries (present in 
actual, missing in expected)\n+++\nexample\n=========\n1 missing entries 
(missing in actual, present in expected)\n---\nwrong"
2023/09/07 22:18:52 INFO stopping worker 
job-064[go-job-64-1694125132362993572]_go 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/extworker/extworker.go>:117
 time=2023-09-07T22:18:52.378Z 
worker.ID=job-064[go-job-64-1694125132362993572]_go 
worker.endpoint=localhost:39965
2023/09/07 22:18:52 INFO Job[job-064] state: FAILED 
source=<https://ci-beam.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/pkg/beam/runners/universal/runnerlib/job.go>:126
 time=2023-09-07T22:18:52.378Z 
worker.ID=job-064[go-job-64-1694125132362993572]_go 
worker.endpoint=localhost:39965
FAIL
FAIL    github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert      1.374s
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/testing/ptest        0.106s
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/testing/teststream   0.008s
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/filter    0.440s
?       github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/sql/sqlx  [no 
test files]
?       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/transforms/xlang/schema      
[no test files]
?       github.com/apache/beam/sdks/v2/go/pkg/beam/util/diagnostics     [no 
test files]
?       github.com/apache/beam/sdks/v2/go/pkg/beam/util/execx   [no test files]
?       github.com/apache/beam/sdks/v2/go/pkg/beam/util/grpcx   [no test files]
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/periodic  0.141s
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/sql       0.008s
?       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]
?       github.com/apache/beam/sdks/v2/go/pkg/beam/x/hooks/perf [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/pkg/beam/transforms/stats     22.815s
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/top       0.207s
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/util/errorx  (cached)
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/util/fsx     (cached)
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/util/gcsx    0.013s
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/util/harnessopts     0.043s
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/util/pubsubx 1.161s
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       1.497s
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/util/structx (cached)
ok      github.com/apache/beam/sdks/v2/go/pkg/beam/x/debug      0.150s
ok      github.com/apache/beam/sdks/v2/go/test/integration      0.143s
ok      github.com/apache/beam/sdks/v2/go/test/integration/io/bigqueryio        
0.063s
ok      github.com/apache/beam/sdks/v2/go/test/integration/io/fhirio    0.102s
?       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/integration/io/mongodbio 57.977s
ok      github.com/apache/beam/sdks/v2/go/test/integration/io/spannerio 0.061s
ok      github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/bigquery    
0.036s
ok      github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/bigtable    
0.063s
ok      github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/debezium    
0.048s
ok      github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/jdbc        
0.073s
ok      github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka       
0.052s
ok      github.com/apache/beam/sdks/v2/go/test/integration/primitives   0.879s
ok      github.com/apache/beam/sdks/v2/go/test/integration/synthetic    1.047s
ok      
github.com/apache/beam/sdks/v2/go/test/integration/transforms/xlang/dataframe   
0.050s
ok      
github.com/apache/beam/sdks/v2/go/test/integration/transforms/xlang/inference   
0.029s
ok      github.com/apache/beam/sdks/v2/go/test/integration/wordcount    0.332s
ok      github.com/apache/beam/sdks/v2/go/test/integration/xlang        3.824s
ok      github.com/apache/beam/sdks/v2/go/test/regression       0.809s
ok      github.com/apache/beam/sdks/v2/go/test/regression/coders/fromyaml       
0.032s
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

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 8.0.

You can use '--warning-mode all' to show the individual deprecation warnings 
and determine if they come from your own scripts or plugins.

See 
https://docs.gradle.org/7.6.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 5m 49s
17 actionable tasks: 11 executed, 4 from cache, 2 up-to-date

Publishing build scan...
https://ge.apache.org/s/xe3qukyp4gy4q

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]

Reply via email to