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)
