zentol opened a new pull request #15288: URL: https://github.com/apache/flink/pull/15288
The `DeclarativeSlotManager` accounts for the possibility of slot allocation confirmations coming in after the slot has already been freed fully allocated (e.g., through a SlotReport) by checking whether there is still a pending request for that slot. However, this only works properly if the slot was allocated. If the slot was freed in the mean time then it could've already been re-assigned to another job, which result in an IllegalStateException once the confirmation arrives. It can also happen that the slot is reassigned to the same job, which can result in a premature configuration of the allocation. To remedy this we now additionally record the AllocationID for pending allocations (although any random value or allocation counter would work). The allocation confirmation will only be processed if the AllocationIDs are still matching. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
