[jira] [Closed] (FLINK-14744) DataSink cannot be chained

["Jiayi Liao (Jira)" <ji...@apache.org>]

     [ 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)