You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Deepak Nagaraj (Jira)" <ji...@apache.org> on 2022/05/16 20:59:00 UTC
[jira] [Updated] (BEAM-14476) Verbose print causes pipelines to get stuck on FlinkRunner.
[ https://issues.apache.org/jira/browse/BEAM-14476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Deepak Nagaraj updated BEAM-14476:
----------------------------------
Summary: Verbose print causes pipelines to get stuck on FlinkRunner. (was: Verbose logging causes pipelines to get stuck on Flink.)
> Verbose print causes pipelines to get stuck on FlinkRunner.
> -----------------------------------------------------------
>
> Key: BEAM-14476
> URL: https://issues.apache.org/jira/browse/BEAM-14476
> Project: Beam
> Issue Type: Bug
> Components: runner-flink, sdk-py-harness
> Reporter: Robert Bradshaw
> Priority: P2
>
> Minimal reproduction:
>
> {{def _run_pipeline(pipeline):}}
> {{ def process_data(unused):}}
> {{ print('a'*1000)}}
> {{ _ = (}}
> {{ pipeline}}
> {{ | "Create" >> beam.Create(['a']*1000)}}
> {{ | "Process" >> beam.Map(process_data)}}
> {{ )}}
> {{ pipeline.run().wait_until_finish()}}
> See thread at https://lists.apache.org/thread/r971f432mvko4g3hmnrodh8s4n2wkk6p
--
This message was sent by Atlassian Jira
(v8.20.7#820007)