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 a9c139a [FLINK-24859][doc][formats] Make new formats name coherent:
introduce previous names classes to indicate deprecation to the users
add afb29d9 [FLINK-25011][runtime] Introduce vertex parallelism decider
and default implementation.
No new revisions were added by this update.
Summary of changes:
.../generated/all_jobmanager_section.html | 24 +++
.../generated/expert_scheduling_section.html | 24 +++
.../generated/job_manager_configuration.html | 24 +++
.../flink/configuration/JobManagerOptions.java | 71 ++++++++-
.../adaptivebatch/BlockingResultInfo.java | 51 +++++++
.../DefaultVertexParallelismDecider.java | 162 +++++++++++++++++++++
.../adaptivebatch/VertexParallelismDecider.java} | 19 +--
.../DefaultVertexParallelismDeciderTest.java | 141 ++++++++++++++++++
8 files changed, 505 insertions(+), 11 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/BlockingResultInfo.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{operators/sort/InMemorySorterFactory.java
=> scheduler/adaptivebatch/VertexParallelismDecider.java} (63%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDeciderTest.java
