Maximilian Michels created BEAM-8011:
----------------------------------------
Summary: Remove workaround to run unbounded sources in portable
pipelines
Key: BEAM-8011
URL: https://issues.apache.org/jira/browse/BEAM-8011
Project: Beam
Issue Type: Improvement
Components: runner-flink, sdk-java-core
Reporter: Maximilian Michels
Assignee: Maximilian Michels
In the course of BEAM-6730 we added a way to Runner-translate Reads in portable
pipelines. GreedyPipelineFuser was manipulated to let through Reads to the
Runner. The better solution for this problem would have been to remove the
environment from unbounded reads, which will make it a Runner translated
transform.
If in the future we support unbounded reads via a SDF adapter, we can re-add
the environment.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
