Stefan Wachter created BEAM-12477:
-------------------------------------
Summary: pipeline.run() blocks when using FlinkRunner
Key: BEAM-12477
URL: https://issues.apache.org/jira/browse/BEAM-12477
Project: Beam
Issue Type: Bug
Components: runner-flink
Affects Versions: 2.29.0
Reporter: Stefan Wachter
{{pipeline.run()}} is documented to be asynchronous (cf.
[create-your-pipeline|https://beam.apache.org/documentation/pipelines/create-your-pipeline/]).
It seems that when using FlinkRunner (embedded or remote) the call blocks
until the pipeline finishes.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
