[ https://issues.apache.org/jira/browse/FLINK-20513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
godfrey he closed FLINK-20513. ------------------------------ Resolution: Done master: dca86b86..24d60659 > Separate the implementation of BatchExecExchange and StreamExecExchange > ----------------------------------------------------------------------- > > Key: FLINK-20513 > URL: https://issues.apache.org/jira/browse/FLINK-20513 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / Planner > Reporter: godfrey he > Assignee: godfrey he > Priority: Major > Labels: pull-request-available > > The issue will separate the implementation of {{Batch(/Stream)ExecExchange}}, > we will introduce Batch(/Stream)PhysicalExchange which only extends from > {{FlinkPhysicalRel}} , and describes the physical info of {{Exchange}}. > Meanwhile, {{BatchExecExchange}} will be moved into `nodes.exec.batch` > package and will implement ExecNode for Exchange, so do it for > {{StreamExecExchange}}. -- This message was sent by Atlassian Jira (v8.3.4#803005)