You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2023/02/15 07:25:00 UTC
[jira] [Created] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator
Prabhu Joseph created FLINK-31080:
-------------------------------------
Summary: Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator
Key: FLINK-31080
URL: https://issues.apache.org/jira/browse/FLINK-31080
Project: Flink
Issue Type: Bug
Affects Versions: 1.16.1
Reporter: Prabhu Joseph
Due to a timing mismatch between {{DeclarativeSlotPoolService}} and {{{}SlotSharingSlotAllocator{}}}, idle slots are not released.
{{DeclarativeSlotPoolService}} uses {{{}SystemClock#relativeTimeMillis{}}}, i.e., {{{}System.nanoTime{}}}() / 1_000_000, while offering a slot, whereas {{SlotSharingSlotAllocator}} uses {{{}System.currentTimeMillis{}}}() while freeing the reserved slot.
The idle timeout check fails wrongly as "{{{}System.currentTimeMillis(){}}}" will have a very high value compared to "{{{}SystemClock#relativeTimeMillis{}}}".
--
This message was sent by Atlassian Jira
(v8.20.10#820010)