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 c98e1a3 [FLINK-26232][avro] Migrate tests to JUnit5
add 801c8fd [hotfix][runtime] Fix typos.
add 4d42c64 [FLINK-26517][runtime] Normalize the decided parallelism to
power of 2 when using adaptive batch scheduler.
No new revisions were added by this update.
Summary of changes:
.../generated/all_jobmanager_section.html | 8 +--
.../generated/expert_scheduling_section.html | 8 +--
.../generated/job_manager_configuration.html | 8 +--
.../flink/configuration/JobManagerOptions.java | 21 ++++--
flink-end-to-end-tests/test-scripts/test_tpcds.sh | 2 +-
.../adaptivebatch/AdaptiveBatchScheduler.java | 3 +-
.../AdaptiveBatchSchedulerFactory.java | 6 +-
.../DefaultVertexParallelismDecider.java | 75 +++++++++++++++++-----
.../adaptivebatch/AdaptiveBatchSchedulerTest.java | 2 +-
.../AdaptiveBatchSchedulerTestUtils.java | 5 +-
.../DefaultVertexParallelismDeciderTest.java | 40 +++++++++---
.../scheduling/AdaptiveBatchSchedulerITCase.java | 3 +
12 files changed, 127 insertions(+), 54 deletions(-)
