LeoCBS opened a new issue, #32498:
URL: https://github.com/apache/beam/issues/32498
### What happened?
I am trying to run the minimum wordcount Golang example on my local machine,
but Apache Beam stays frozen on reading data from Google Storage, and the
example never ends.
Example output:
```FuZ2UuUmVzdHJpY3Rpb24qBAgZQAE="}}} coders:{key:"c8"
value:{spec:{urn:"beam:coder:length_prefix:v1"} component_coder_ids:"c7"}}
coders:{key:"c9" value:{spec:{urn:"beam:coder:bool:v1"}}}
environments:{key[128/396]
ue:{urn:"beam:env:external:v1" payload:"\n\x11\n\x0flocalhost:33211"
capabilities:"beam:protocol:progress_reporting:v1"
capabilities:"beam:protocol:multi_core_bundle_processing:v1"
capabilities:"beam:transform:sdf_truncate_sized_restrictions:v1"
capabilities:"beam:protocol:worker_status:v1"
capabilities:"beam:protocol:monitoring_info_short_ids:v1"
capabilities:"beam:version:sdk_base:go:apache/beam_go_sdk:2.59.0" capabi
lities:"beam:transform:to_string:v1"
capabilities:"beam:protocol:data_sampling:v1"
capabilities:"beam:protocol:sdk_consuming_received_data:v1"
capabilities:"beam:coder:bytes:v1" capabilities:"beam:coder:bool:v1"
capabilities:"beam:coder:varint:v1" capabilities:"beam:coder:double:v1"
capabilities:"beam:coder:string_utf8:v1"
capabilities:"beam:coder:length_prefix:v1" capabilities:"beam:coder:kv:v1"
capabilities:"beam:cod
er:iterable:v1" capabilities:"beam:coder:state_backed_iterable:v1"
capabilities:"beam:coder:windowed_value:v1"
capabilities:"beam:coder:global_window:v1"
capabilities:"beam:coder:interval_window:v1" capabilities:"beam:coder:row:v1"
capabilities:"beam:coder:nullable:v1" capabilities:"beam:coder:timer:v1"
dependencies:{type_urn:"beam:artifact:type:file:v1"
role_urn:"beam:artifact:role:go_worker_binary:v1"}}}} root_transf
orm_ids:"s1" root_transform_ids:"e6" root_transform_ids:"s4"
root_transform_ids:"e10" root_transform_ids:"s7"
requirements:"beam:requirement:pardo:splittable_dofn:v1"
2024/09/18 09:43:33 Prepared job with id: job-001 and
staging token: job-001
2024/09/18 09:43:33 Staged binary artifact with token: job-001
2024/09/18 09:43:33
Submitted job: job-001
2024/09/18 09:43:33 (): starting job-001[go-job-1-1726663413483254464]
2024/09/18 09:43:33 ():
running job-001[go-job-1-1726663413483254464]
2024/09/18 09:43:33 Job[job-001] state: RUNNING
2024/09/18 09:43:33
starting worker job-001[go-job-1-1726663413483254464]_go
2024/09/18 09:43:34 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:34.827Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.026Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.129Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.228Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.228Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.331Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.331Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.331Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.438Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.834Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.843Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.872Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:35 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:35.982Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:36 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:36.019Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:36 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:36.107Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
2024/09/18 09:43:36 INFO Reading from
gs://apache-beam-samples/shakespeare/kinglear.txt
source=/home/leonardo-borges/projects/go/pkg/mod/github.com/apache/beam/sdks/[email protected]/go/pkg/beam/io/textio/textio.go:226
time=2024-09-18T12:43:36.181Z
worker.ID=job-001[go-job-1-1726663413483254464]_go
worker.endpoint=localhost:45985
```
### Issue Priority
Priority: 2 (default / most bugs should be filed as P2)
### Issue Components
- [ ] Component: Python SDK
- [ ] Component: Java SDK
- [X] Component: Go SDK
- [ ] Component: Typescript SDK
- [ ] Component: IO connector
- [ ] Component: Beam YAML
- [X] Component: Beam examples
- [ ] Component: Beam playground
- [ ] Component: Beam katas
- [ ] Component: Website
- [ ] Component: Infrastructure
- [ ] Component: Spark Runner
- [ ] Component: Flink Runner
- [ ] Component: Samza Runner
- [ ] Component: Twister2 Runner
- [ ] Component: Hazelcast Jet Runner
- [ ] Component: Google Cloud Dataflow Runner
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
