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

Posted to issues@flink.apache.org by "Lei Yang (Jira)" <ji...@apache.org> on 2024/08/16 06:08:00 UTC

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

    [ https://issues.apache.org/jira/browse/FLINK-36066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874117#comment-17874117 ] 

Lei Yang commented on FLINK-36066:
----------------------------------

I would like to work on this task. 

> 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
>            Priority: Major
>
> 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)