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] [Updated] (BEAM-8658) Optionally set artifact staging port in FlinkUberJarJobServer

     [ https://issues.apache.org/jira/browse/BEAM-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kyle Weaver updated BEAM-8658:
------------------------------
    Status: Open  (was: Triage Needed)

> 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
>            Priority: Major
>              Labels: portability-flink
>
> 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)