This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0f701b5 [FLINK-25818][Docs][Kafka] Add explanation how Kafka Source
deals with idleness when parallelism is higher then the number of partitions
add d7bc8e2 [FLINK-25673][tests] Wait until all slots are freed
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/minicluster/MiniCluster.java | 21 ++++++++++++
.../runtime/testutils/MiniClusterResource.java | 39 ++++++++++++++++++----
.../test/scheduling/AdaptiveSchedulerITCase.java | 7 ++--
3 files changed, 58 insertions(+), 9 deletions(-)
