Kyle Weaver created BEAM-8658:
---------------------------------

             Summary: Optionally set artifact staging port in 
FlinkUberJarJobServer
                 Key: BEAM-8658
                 URL: https://issues.apache.org/jira/browse/BEAM-8658
             Project: Beam
          Issue Type: Improvement
          Components: runner-flink
            Reporter: Kyle Weaver
            Assignee: Kyle Weaver


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

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to