You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Kyle Weaver (Jira)" <ji...@apache.org> on 2019/11/13 23:42:00 UTC

[jira] [Created] (BEAM-8658) Optionally set artifact staging port in FlinkUberJarJobServer

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)