Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-36068][runtime] Support scheduling based on adaptive job graph. #25658

Draft
wants to merge 8 commits into
base: master
Choose a base branch
from
Draft

[FLINK-36068][runtime] Support scheduling based on adaptive job graph. #25658

wants to merge 8 commits into from

Commits on Nov 25, 2024

  1. [FLINK-36066][runtime] Introduce ImmutableStreamGraph to provide a re… 

    …ad-only view of StreamGraph
    @noorall @JunRuiLee
    noorall authored and JunRuiLee committed Nov 25, 2024
    Configuration menu
    Copy the full SHA
    8df4b59 View commit details
    Browse the repository at this point in the history

  2. [FLINK-36066][runtime] Introduce StreamGraphContext to provide the ab… 

    …ility to modify the StreamGraph
    @noorall @JunRuiLee
    noorall authored and JunRuiLee committed Nov 25, 2024
    Configuration menu
    Copy the full SHA
    142e41b View commit details
    Browse the repository at this point in the history

  3. [FLINK-36066][runtime] Further Improve Method Reusability in Streamin… 

    …gJobGraphGenerator
    @noorall @JunRuiLee
    noorall authored and JunRuiLee committed Nov 25, 2024
    Configuration menu
    Copy the full SHA
    108d49d View commit details
    Browse the repository at this point in the history

  4. [FLINK-36066][runtime] Introduce the AdaptiveGraphManager component

    @noorall @JunRuiLee
    noorall authored and JunRuiLee committed Nov 25, 2024
    Configuration menu
    Copy the full SHA
    5840f53 View commit details
    Browse the repository at this point in the history

Commits on Nov 26, 2024

  1. apply spotless

    @JunRuiLee
    JunRuiLee committed Nov 26, 2024
    Configuration menu
    Copy the full SHA
    6dda683 View commit details
    Browse the repository at this point in the history

  2. [FLINK-36068][runtime] Force the number of subpartitions to always be… 

    … one for forward edges.
    @JunRuiLee
    JunRuiLee committed Nov 26, 2024
    Configuration menu
    Copy the full SHA
    81ae340 View commit details
    Browse the repository at this point in the history

  3. [FLINK-36068][runtime] Introduce AdaptiveExecutionHandler for handlin… 

    …g the adaptive execution of batch jobs.
    @JunRuiLee
    JunRuiLee committed Nov 26, 2024
    Configuration menu
    Copy the full SHA
    be392bb View commit details
    Browse the repository at this point in the history

  4. [FLINK-36068][runtime] Support scheduling based on adaptive job graph.

    @JunRuiLee
    JunRuiLee committed Nov 26, 2024
    Configuration menu
    Copy the full SHA
    17cca69 View commit details
    Browse the repository at this point in the history