Maximilian Michels created BEAM-8010:
----------------------------------------
Summary: Remove translation of bounded reads from portable Flink
runner
Key: BEAM-8010
URL: https://issues.apache.org/jira/browse/BEAM-8010
Project: Beam
Issue Type: Improvement
Components: runner-flink
Reporter: Maximilian Michels
Assignee: Maximilian Michels
In the course of BEAM-6730 we added a way to Runner-translate bounded and
unbounded Reads in portable pipelines. However, bounded Reads are already
supported via Impulse + BoundedReadViaImpulse.
This can be fixed by removing the bounded read translators from portable
pipelines.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
