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 2021/02/23 07:44:18 UTC

[flink] branch master updated (6c99802 -> e92afd3)

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 6c99802  [FLINK-21180][python] Move the state module from 'pyflink.common' to 'pyflink.datastream'
     add d8e469d  [hotfix][runtime] Fix unstable TaskManagerCheckInSlotManagerTest#testTaskManagerIsNotReleasedInCaseOfConcurrentAllocation
     add f286557  [hotfix][runtime] Move generating PendingTaskManagerId to inside PendingTaskManager.
     add 02d88aa  [hotfix][core] Update Resource#hashCode() to ignore BigDecimal scale.
     add e92afd3  [FLINK-21433][runtime] Replace defaultSlotProfile with numSlots for creating PendingTaskManager.

No new revisions were added by this update.

Summary of changes:
 .../flink/api/common/resources/Resource.java       |  3 +-
 .../flink/api/common/resources/ResourceTest.java   |  7 +++
 .../DefaultResourceAllocationStrategy.java         | 18 +++----
 .../slotmanager/PendingTaskManager.java            | 16 +++---
 .../slotmanager/SlotManagerUtils.java              | 21 ++++++++
 .../taskexecutor/TaskExecutorResourceUtils.java    | 10 +++-
 .../DefaultResourceAllocationStrategyTest.java     | 11 ++--
 .../slotmanager/FineGrainedSlotManagerTest.java    | 18 +++----
 .../FineGrainedTaskManagerTrackerTest.java         | 45 ++++++++--------
 .../slotmanager/SlotManagerUtilsTest.java          | 60 +++++++++++++++++++++-
 .../TaskManagerCheckInSlotManagerTest.java         |  5 ++
 11 files changed, 157 insertions(+), 57 deletions(-)