julianogalgaro commented on issue #32498: URL: https://github.com/apache/beam/issues/32498#issuecomment-2358441544
Same issue here, running the example command from: https://beam.apache.org/get-started/quickstart-go/ Downloading the file from GCS the process finishes successfully in seconds. 🤔 ``` â•â”€ ï…¹   ~ ─────────────────────────────────────────────────────────────────────────────────────────────────────────────── ✔  10:07:57  ─╮ ╰─ go run github.com/apache/beam/sdks/v2/go/examples/wordcount@latest --input "gs://apache-beam-samples/shakespeare/kinglear.txt" --output counts 2024/09/18 10:08:08 INFO Serving JobManagement endpoint=localhost:60915 2024/09/18 10:08:08 starting Loopback server at 127.0.0.1:60916 ... 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" capabilities:"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:coder:iterable:v1" capabilities:"beam:coder:state_backed_iterable:v1" capabilities:"beam:coder:windowed_value:v1" capabilities:"beam:coder:global_window:v1" capabilities:"beam:coder:interval_window:v1" capabilities:"beam:coder:row:v1" 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_transform_ids:"s1" root_transform_ids:"s4" root_transform_ids:"e10" root_transform_ids:"s8" requirements:"beam:requirement:pardo:splittable_dofn:v1" 2024/09/18 10:08:08 Prepared job with id: job-001 and staging token: job-001 2024/09/18 10:08:08 Staged binary artifact with token: job-001 2024/09/18 10:08:08 Submitted job: job-001 2024/09/18 10:08:08 (): starting job-001[go-job-1-1726664888026831000] 2024/09/18 10:08:08 (): running job-001[go-job-1-1726664888026831000] 2024/09/18 10:08:08 Job[job-001] state: RUNNING 2024/09/18 10:08:08 starting worker job-001[go-job-1-1726664888026831000]_go 2024/09/18 10:08:10 INFO Reading from gs://apache-beam-samples/shakespeare/kinglear.txt source=/Users/julianogalgaro/go/pkg/mod/github.com/apache/beam/sdks/v2@v2.59.0/go/pkg/beam/io/textio/textio.go:226 time=2024-09-18T13:08:10.038Z worker.ID=job-001[go-job-1-1726664888026831000]_go worker.endpoint=localhost:60919 2024/09/18 10:08:10 INFO Reading from gs://apache-beam-samples/shakespeare/kinglear.txt source=/Users/julianogalgaro/go/pkg/mod/github.com/apache/beam/sdks/v2@v2.59.0/go/pkg/beam/io/textio/textio.go:226 time=2024-09-18T13:08:10.239Z worker.ID=job-001[go-job-1-1726664888026831000]_go worker.endpoint=localhost:60919 2024/09/18 10:08:10 INFO Reading from gs://apache-beam-samples/shakespeare/kinglear.txt source=/Users/julianogalgaro/go/pkg/mod/github.com/apache/beam/sdks/v2@v2.59.0/go/pkg/beam/io/textio/textio.go:226 time=2024-09-18T13:08:10.438Z worker.ID=job-001[go-job-1-1726664888026831000]_go worker.endpoint=localhost:60919 2024/09/18 10:08:10 INFO Reading from gs://apache-beam-samples/shakespeare/kinglear.txt source=/Users/julianogalgaro/go/pkg/mod/github.com/apache/beam/sdks/v2@v2.59.0/go/pkg/beam/io/textio/textio.go:226 time=2024-09-18T13:08:10.541Z worker.ID=job-001[go-job-1-1726664888026831000]_go worker.endpoint=localhost:60919 2024/09/18 10:08:10 INFO Reading from gs://apache-beam-samples/shakespeare/kinglear.txt source=/Users/julianogalgaro/go/pkg/mod/github.com/apache/beam/sdks/v2@v2.59.0/go/pkg/beam/io/textio/textio.go:226 time=2024-09-18T13:08:10.640Z worker.ID=job-001[go-job-1-1726664888026831000]_go worker.endpoint=localhost:60919 ``` -- 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: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
