Junrui Li created FLINK-36066:
---------------------------------

             Summary: 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


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)

Reply via email to