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)

Reply via email to