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

Posted to commits@flink.apache.org by xt...@apache.org on 2023/01/12 03:27:12 UTC

[flink] branch master updated (086f13a9cd6 -> f611ea8cb5d)

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

xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 086f13a9cd6 [FLINK-30375][Table SQL / Client] sql-client leaks flink-table-planner jar in /tmp (#21512)
     add f611ea8cb5d [FLINK-18229][ResourceManager] Support cancel pending workers when it's no longer needed.

No new revisions were added by this update.

Summary of changes:
 .../KubernetesResourceManagerDriver.java           |  21 +-
 .../KubernetesResourceManagerDriverTest.java       |  54 +++++
 .../active/ActiveResourceManager.java              | 153 +++++++++---
 .../active/ResourceManagerDriver.java              |   4 +
 .../slotmanager/DeclarativeSlotManager.java        |  11 +-
 .../slotmanager/FineGrainedSlotManager.java        |  54 +++--
 .../slotmanager/FineGrainedTaskManagerTracker.java |  13 +
 .../slotmanager/TaskExecutorManager.java           |  33 +++
 .../active/ActiveResourceManagerTest.java          | 261 +++++++++------------
 .../slotmanager/DeclarativeSlotManagerTest.java    |   9 +-
 .../slotmanager/FineGrainedSlotManagerTest.java    |  12 +-
 .../flink/yarn/YarnResourceManagerDriver.java      |  60 ++++-
 .../flink/yarn/YarnResourceManagerDriverTest.java  |  33 +++
 13 files changed, 496 insertions(+), 222 deletions(-)