[jira] [Created] (FLINK-20490) Don't share inputs between FlinkPhysicalRel and ExecNode

[Shang Yuanchun (Jira)]

godfrey he created FLINK-20490:
----------------------------------

             Summary: Don't share inputs between FlinkPhysicalRel and ExecNode
                 Key: FLINK-20490
                 URL: https://issues.apache.org/jira/browse/FLINK-20490
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / Planner
            Reporter: godfrey he


Currently, all execution nodes extend both from {{RelNode}} and {{ExecNode}}, and they share same input instances which is stored in the {{RelNode}} instance. {{ExecNode#getInputNodes}} just returns the casted {{RelNode}} inputs, code likes:

{code:java}
getInputs.map(_.asInstanceOf[ExecNode[_]])
{code}

This issue aim to let {{ExecNode}} have its own input instance. It is prepared for the implementation separation between {{RelNode}} and {{ExecNode}}.




--
This message was sent by Atlassian Jira
(v8.3.4#803005)