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

Posted to issues@flink.apache.org by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/12 11:00:00 UTC

[jira] [Updated] (FLINK-36067) Support optimize stream graph based on input info.

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

Junrui Lee updated FLINK-36067:
-------------------------------
    Summary: Support optimize stream graph based on input info.  (was: Introducing the StreamGraphOptimizer component)

> Support optimize stream graph based on input info.
> --------------------------------------------------
>
>                 Key: FLINK-36067
>                 URL: https://issues.apache.org/jira/browse/FLINK-36067
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Coordination
>            Reporter: Junrui Li
>            Assignee: Junrui Lee
>            Priority: Major
>              Labels: pull-request-available
>
> To support optimize the StreamGraph based on runtime information, we plan to introduce the StreamGraphOptimizer component. This component, upon initialization, will obtain the StreamGraphContext from the AdaptiveGraphManager. And this component will load a set of StreamGraphOptimizationStrategies. At runtime, it will pass the received OperatorsFinished and the StreamGraphContext sequentially to all StreamGraphOptimizationStrategies, attempting to optimize the StreamGraph.



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