frankljin opened a new issue, #30703: URL: https://github.com/apache/beam/issues/30703
### What happened? To replicate this issue: 1. Clone the beam-starter-go pipeline [here](https://beam.apache.org/get-started/quickstart/go/) 2. Run it using the command. Worker logs should appear as expected ("Hello", "World!", "Greetings", one per line) 3. Now, trying to run it using the stand-alone binary [here](https://pkg.go.dev/github.com/apache/beam/sdks/v2/go/cmd/prism) using this command: ``` go run main.go --input-text="Greetings" --runner=universal --endpoint=localhost:8073 --environment_type=LOOPBACK ``` 4. Worker logs do not show up. Pipelines setup logs do show up (like pipelines graph creation, etc) From my understanding, both of these are run on the Prism runner. Comparing the excerpts: (stand-alone binary) ``` 2024/03/21 18:13:23 Submitted job: job-013 2024/03/21 18:13:23 (): starting job-013[go-job-1-1711044803815930815] 2024/03/21 18:13:23 (): running job-013[go-job-1-1711044803815930815] 2024/03/21 18:13:23 Job[job-013] state: RUNNING 2024/03/21 18:13:23 starting worker job-013[go-job-1-1711044803815930815]_go 2024/03/21 18:13:23 (): pipeline completed job-013[go-job-1-1711044803815930815] 2024/03/21 18:13:23 stopping worker job-013[go-job-1-1711044803815930815]_go 2024/03/21 18:13:23 (): terminating job-013[go-job-1-1711044803815930815] ``` (command in the quickstart) ``` 2024/03/21 18:14:03 Submitted job: job-001 2024/03/21 18:14:03 (): starting job-001[go-job-1-1711044843837533764] 2024/03/21 18:14:03 (): running job-001[go-job-1-1711044843837533764] 2024/03/21 18:14:03 Job[job-001] state: RUNNING 2024/03/21 18:14:03 starting worker job-001[go-job-1-1711044843837533764]_go 2024/03/21 18:14:03 INFO Hello source=/redacted/beam-starter-go/main.go:36 time=2024-03-21T18:14:03.849Z worker.ID=job-001[go-job-1-1711044843837533764]_go worker.endpoint=localhost:36291 2024/03/21 18:14:03 INFO World! source=/redacted/beam-starter-go/main.go:36 time=2024-03-21T18:14:03.849Z worker.ID=job-001[go-job-1-1711044843837533764]_go worker.endpoint=localhost:36291 2024/03/21 18:14:03 INFO Greetings source=/redacted/beam-starter-go/main.go:36 time=2024-03-21T18:14:03.849Z worker.ID=job-001[go-job-1-1711044843837533764]_go worker.endpoint=localhost:36291 2024/03/21 18:14:03 stopping worker job-001[go-job-1-1711044843837533764]_go 2024/03/21 18:14:03 control response channel closed ``` ### Issue Priority Priority: 3 (minor) ### 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: 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: github-unsubscr...@beam.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
