You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/15 09:03:00 UTC

[jira] [Assigned] (FLINK-20513) Separate the implementation of BatchExecExchange and StreamExecExchange

     [ https://issues.apache.org/jira/browse/FLINK-20513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

godfrey he reassigned FLINK-20513:
----------------------------------

    Assignee: godfrey he

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