[
https://issues.apache.org/jira/browse/BEAM-14476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Bradshaw updated BEAM-14476:
-----------------------------------
Description:
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
was:
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()}}
> Verbose logging causes pipelines to get stuck on Flink.
> -------------------------------------------------------
>
> 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)
