Jiayi Liao created FLINK-14744:
----------------------------------
Summary: Neighboring vertex should be chained if ship strategy is FORWARD or NONE
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
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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)