[
https://issues.apache.org/jira/browse/FLINK-14744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-14744.
------------------------------
Resolution: Not A Problem
> DataSink cannot be chained
> --------------------------
>
> Key: FLINK-14744
> URL: https://issues.apache.org/jira/browse/FLINK-14744
> Project: Flink
> Issue Type: Improvement
> Components: Client / Job Submission
> Affects Versions: 1.9.0
> Reporter: Jiayi Liao
> Priority: Major
>
> Assuming that I have a job and the unchained graph is like :
> {code:java}
> Data Source(parallelism=5) -> Map (parallelism=5) -> DataSink
> (parallelism=5){code}
> The {{JobGraphGenerator}} will chained {{Data Source}} and {{Map}}, and use
> {{FORWARD}} to connect the chained task and {{DataSink}} task.
>
> I think \{{DataSink}} should be chained into the same task too.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
