[jira] [Created] (FLINK-19623) Introduce ExecEdge to describe information on input edges for ExecNode

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-19623) Introduce ExecEdge to describe information on input edges for ExecNode

Shang Yuanchun (Jira)
Caizhi Weng created FLINK-19623:
-----------------------------------

             Summary: Introduce ExecEdge to describe information on input edges for ExecNode
                 Key: FLINK-19623
                 URL: https://issues.apache.org/jira/browse/FLINK-19623
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / Planner
            Reporter: Caizhi Weng
             Fix For: 1.12.0


Deadlock breakup algorithm and Multi-input operator creation algorithm need information about the input edges of an exec node, for example what's the priority of this input, and how the input records will trigger the output records.

We're going to introduce a new class {{ExecEdge}} to describe this.



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