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

Posted to commits@flink.apache.org by zh...@apache.org on 2022/01/11 06:50:05 UTC

[flink] branch master updated (562344b -> 47a520b)

This is an automated email from the ASF dual-hosted git repository.

zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 562344b  [FLINK-25230][table-planner] Regenerate JSON plans
     add d2bfe40  [FLINK-25032][runtime] Allow ExecutionJobVertex to be initialized lazily.
     add 3b1f15c  [FLINK-25032][runtime] Allow parallelism of ExecutionJobVertex to be decided lazily.
     add 47a520b  [FLINK-25032][runtime] Enable to create a dynamic graph.

No new revisions were added by this update.

Summary of changes:
 .../executiongraph/DefaultExecutionGraph.java      | 105 +++++++----
 .../DefaultExecutionGraphBuilder.java              |  11 +-
 .../runtime/executiongraph/ExecutionGraph.java     |  10 +
 .../runtime/executiongraph/ExecutionJobVertex.java |  69 +++++--
 .../scheduler/DefaultExecutionGraphFactory.java    |  31 +++-
 .../flink/runtime/scheduler/DefaultScheduler.java  |   3 +-
 .../scheduler/DefaultVertexParallelismInfo.java    |  22 ++-
 .../flink/runtime/scheduler/SchedulerBase.java     |  26 ++-
 .../scheduler/VertexParallelismInformation.java    |   8 +
 .../adapter/DefaultExecutionTopology.java          |   2 +-
 .../DefaultExecutionGraphConstructionTest.java     |  28 +++
 .../executiongraph/ExecutionJobVertexTest.java     | 203 +++++++++++++++++++++
 .../TestingDefaultExecutionGraphBuilder.java       |  14 +-
 .../DefaultVertexParallelismInfoTest.java          |  45 ++++-
 .../DefaultVertexParallelismStoreTest.java         |   3 +
 .../runtime/scheduler/adaptive/ExecutingTest.java  |   4 +-
 .../adaptive/StateTrackingMockExecutionGraph.java  |   6 +
 17 files changed, 517 insertions(+), 73 deletions(-)