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)