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

Posted to issues@flink.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/09/27 03:46:00 UTC

[jira] [Updated] (FLINK-36066) Introducing the AdaptiveGraphGenerator component

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

ASF GitHub Bot updated FLINK-36066:
-----------------------------------
    Labels: pull-request-available  (was: )

> Introducing the AdaptiveGraphGenerator component
> ------------------------------------------------
>
>                 Key: FLINK-36066
>                 URL: https://issues.apache.org/jira/browse/FLINK-36066
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Coordination
>            Reporter: Junrui Li
>            Assignee: Lei Yang
>            Priority: Major
>              Labels: pull-request-available
>
> To support the incremental generation of JobGraph and update the StreamGraph based on runtime information, we plan to introduce the AdaptiveGraphManager component, which will implement the AdaptiveGraphGenerator interface. The AdaptiveGraphGenerator interface is responsible for:
>  # Generating the JobGraph
>  # Responding to upstream job vertex finished events, generating JobVertex, and updating it to the JobGraph
>  # Providing StreamGraphContext to allow StreamGraphOptimizer to add, delete, and modify StreamNode and StreamEdge



--
This message was sent by Atlassian Jira
(v8.20.10#820010)