[
https://issues.apache.org/jira/browse/BEAM-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía resolved BEAM-1993.
--------------------------------
Resolution: Fixed
> Remove special unbounded Flink source/sink
> ------------------------------------------
>
> Key: BEAM-1993
> URL: https://issues.apache.org/jira/browse/BEAM-1993
> Project: Beam
> Issue Type: Improvement
> Components: runner-flink
> Reporter: Aljoscha Krettek
> Assignee: Ismaël Mejía
> Fix For: First stable release
>
>
> {{UnboundedFlinkSource}} and {{UnboundedFlinkSink}} allow using a Flink
> {{SourceFunction}}/{{SinkFunction}} with Beam. They only work on the Flink
> Runner since they directly pass through the function. This doesn't play well
> with Runner portability and was there in the beginning because Beam didn't
> yet have a rich ecosystem of connectors.
> Once we remove this we can also remove the flink/examples package because the
> only custom stuff left there is examples showcasing the use of Flink
> sources/sinks.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
