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/14 18:15:00 UTC

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

    [ https://issues.apache.org/jira/browse/BEAM-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16974468#comment-16974468 ] 

Kyle Weaver edited comment on BEAM-8658 at 11/14/19 6:14 PM:
-------------------------------------------------------------

Another option to consider is making the artifact staging server in-process.

Edit: Unfortunately, it doesn't look like the GRPC Python API supports in-process channels.


was (Author: ibzib):
Another option to consider is making the artifact staging server in-process.

> 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)