You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/06/04 21:34:41 UTC

[GitHub] [beam] damccorm opened a new issue, #21087: Add ability to specify gRPC server/worker ports

damccorm opened a new issue, #21087:
URL: https://github.com/apache/beam/issues/21087

   My development setup is all Docker-based and I work inside a Docker container for development. From this docker environment, i'd love to be able to [run a pipeline with a custom container image](https://beam.apache.org/documentation/runtime/environments/) for local testing. I've been able to launch a sister beam docker container from my main docker container, but am running into an issue with the ports.
   
   It would be really helpful if I could set a value for the control_address and logging_endpoint of the GrpcServer for the portable runner worker.
   
   The 'docker run' command passes in a control_address [here](https://github.com/apache/beam/blob/2aab1b04c2f5002527e0f2d25075b282feb7c054/sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py#L767-L769) which ultimately comes from [here.](https://github.com/apache/beam/blob/2aab1b04c2f5002527e0f2d25075b282feb7c054/sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py#L464) Similarly, the logging_endpoint passed in  [here](https://github.com/apache/beam/blob/2aab1b04c2f5002527e0f2d25075b282feb7c054/sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py#L766) comes from [here](https://github.com/apache/beam/blob/2aab1b04c2f5002527e0f2d25075b282feb7c054/sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py#L515).
   
   This would be a pretty small change, just exposing some knob to configure those endpoints rather than having them chosen by the gRPC server. Thanks!!
   
   Imported from Jira [BEAM-12580](https://issues.apache.org/jira/browse/BEAM-12580). Original Jira may contain additional context.
   Reported by: mhoeger.


-- 
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-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org