Thomas Weise commented on BEAM-2591:

Implementation in my mind related more to the operational side of things (extra 
JVM process that needs to be maintained just for launching the Beam pipelines). 
And yes, it would probably make sense to embed that into whatever pipeline 
management solution exists natively for the runner. 

> Python shim for submitting to FlinkRunner
> -----------------------------------------
>                 Key: BEAM-2591
>                 URL: https://issues.apache.org/jira/browse/BEAM-2591
>             Project: Beam
>          Issue Type: Sub-task
>          Components: runner-flink, sdk-py-core
>            Reporter: Kenneth Knowles
>            Priority: Major
>              Labels: portability
> Whatever the result of https://s.apache.org/beam-job-api, Python users will 
> need to be able to pass --runner=FlinkRunner and have it work.

This message was sent by Atlassian JIRA

Reply via email to