Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-36033 FLIP-469: Supports Adaptive Optimization of StreamGraph
  3. FLINK-36067

Introducing the StreamGraphOptimizer component

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • Runtime / Coordination
    • None

    Description

      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.

      Attachments

        Activity

          People

            Unassigned Unassigned
            JunRuiLi Junrui Li
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: