zentol opened a new pull request #14382:
URL: https://github.com/apache/flink/pull/14382


   It is possible that a notification from a task executor about a slot being 
allocated can be processed after that very task executor has unregistered 
itself from the resource manager.
   As a result we run into an exception when trying to mark this slot as 
allocated, because it no longer exists and a precondition catches this case.
   
   We could solve this by checking in `DeclarativeResourceManager#allocateSlot` 
whether the task executor from which we received the acknowledgement from is 
still registered.
   


----------------------------------------------------------------
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:
us...@infra.apache.org


Reply via email to