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 9b2711ac42d [FLINK-28551][network] Store the number of bytes instead
of the number of buffers in index entry for sort-shuffle
add 022374b772a [hotfix][runtime][tests] Migrates some tests to Junit5
add 6f7455b078b [FLINK-28145][runtime] Introduce BlockedTaskManagerChecker
into SlotManager to avoid allocating slots that located on blocked nodes.
add 9815caad271 [FLINK-28145][runtime] Let ResourceManagerDriver support
filtering out blocked nodes when requesting new TMs from external resource
managers
add 2e5cac1f31a [FLINK-28145][runtime] Let ResourceManager support
blocklist
No new revisions were added by this update.
Summary of changes:
.../KubernetesResourceManagerDriver.java | 9 +-
.../configuration/KubernetesConfigOptions.java | 13 +
.../decorators/InitTaskManagerDecorator.java | 34 ++
.../KubernetesTaskManagerParameters.java | 15 +-
.../flink/kubernetes/KubernetesTestUtils.java | 3 +-
.../kubeclient/KubernetesTaskManagerTestBase.java | 10 +-
.../decorators/InitTaskManagerDecoratorTest.java | 24 ++
.../KubernetesTaskManagerParametersTest.java | 3 +-
.../runtime/blocklist/BlockedNodeRetriever.java | 16 +-
.../runtime/resourcemanager/ResourceManager.java | 41 ++-
.../resourcemanager/ResourceManagerGateway.java | 3 +-
.../resourcemanager/StandaloneResourceManager.java | 3 +
.../StandaloneResourceManagerFactory.java | 2 +
.../active/AbstractResourceManagerDriver.java | 13 +-
.../active/ActiveResourceManager.java | 9 +-
.../active/ActiveResourceManagerFactory.java | 2 +
.../active/ResourceManagerDriver.java | 5 +-
.../slotmanager/DeclarativeSlotManager.java | 37 +-
.../DefaultResourceAllocationStrategy.java | 16 +-
.../slotmanager/FineGrainedSlotManager.java | 22 +-
.../slotmanager/ResourceAllocationStrategy.java | 5 +-
.../resourcemanager/slotmanager/SlotManager.java | 11 +-
.../resourcemanager/ResourceManagerTest.java | 181 ++++++----
.../StandaloneResourceManagerTest.java | 2 +
.../resourcemanager/TestingResourceManager.java | 3 +
.../TestingResourceManagerFactory.java | 5 +
.../active/ActiveResourceManagerTest.java | 2 +
.../active/ResourceManagerDriverTestBase.java | 9 +-
.../active/TestingResourceManagerDriver.java | 4 +-
.../AbstractFineGrainedSlotManagerITCase.java | 154 +++++----
.../slotmanager/DeclarativeSlotManagerBuilder.java | 13 +-
.../slotmanager/DeclarativeSlotManagerTest.java | 373 +++++++++++----------
.../DefaultResourceAllocationStrategyTest.java | 93 +++--
...gerDefaultResourceAllocationStrategyITCase.java | 11 +-
.../slotmanager/FineGrainedSlotManagerTest.java | 330 ++++++++----------
.../FineGrainedSlotManagerTestBase.java | 37 +-
.../TestingResourceAllocationStrategy.java | 4 +-
.../slotmanager/TestingSlotManager.java | 14 +-
.../slotmanager/TestingSlotManagerBuilder.java | 10 +-
.../utils/TestingResourceManagerGateway.java | 6 +
.../TaskManagerDisconnectOnShutdownITCase.java | 2 +
.../flink/yarn/AMRMClientAsyncReflector.java | 128 +++++++
.../flink/yarn/YarnResourceManagerDriver.java | 35 +-
.../flink/yarn/TestingYarnAMRMClientAsync.java | 17 +
.../flink/yarn/YarnResourceManagerDriverTest.java | 47 +++
45 files changed, 1183 insertions(+), 593 deletions(-)
copy
flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/QsConstants.java
=>
flink-runtime/src/main/java/org/apache/flink/runtime/blocklist/BlockedNodeRetriever.java
(72%)
create mode 100644
flink-yarn/src/main/java/org/apache/flink/yarn/AMRMClientAsyncReflector.java
