[BEAM-8658] Optionally set artifact staging port in FlinkUberJarJobServer

• Type: Improvement
• Status: Triage Needed
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.18.0
• Component/s: runner-flink
• Labels: portability-flink
• Assignee: Kyle Weaver
• Reporter: Kyle Weaver
• Created: 13/Nov/19 23:41
• Updated: 13/Apr/23 10:58
• Resolved: 22/Nov/19 22:19

Description

In certain network environments, port forwarding is necessary for our GRPC servers, such as the artifact staging server. Currently, the port for FlinkUberJarJobServer's artifact staging server is chosen randomly (0). We will need to let the user choose it if they are to forward that port.

https://github.com/apache/beam/blob/802e7cd86024c21d7b2eeb45f0e7c8e370661610/sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py#L129

 

Issue Links

• relates to: BEAM-8796 Optionally configure static job port for JavaJarJobServer
• links to: GitHub Pull Request #10163