[
https://issues.apache.org/jira/browse/FLINK-36066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Li updated FLINK-36066:
------------------------------
Description:
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
was:
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
> 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)
