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

Posted to commits@flink.apache.org by wa...@apache.org on 2023/02/15 06:16:47 UTC

[flink] branch release-1.16 updated (14531dac756 -> d83044908a0)

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

wanglijie pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 14531dac756 [FLINK-30864][FLINK-30885][CEP] Fix wrong NFA related to optional decoration at the beginning of group pattern
     add d83044908a0 [FLINK-30917][runtime] Let adaptive batch scheduler also respect the user-configured max parallelism when deciding parallelism

No new revisions were added by this update.

Summary of changes:
 .../adaptivebatch/AdaptiveBatchScheduler.java      |   5 +-
 .../DefaultVertexParallelismDecider.java           | 112 +++++++++++++++------
 .../adaptivebatch/VertexParallelismDecider.java    |   9 +-
 .../runtime/scheduler/DefaultSchedulerBuilder.java |   2 +-
 .../adaptivebatch/AdaptiveBatchSchedulerTest.java  | 106 +++++++++++++++++--
 .../DefaultVertexParallelismDeciderTest.java       |  71 +++++++------
 .../adaptivebatch/SpeculativeSchedulerTest.java    |   2 +-
 7 files changed, 236 insertions(+), 71 deletions(-)