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)