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(-)
