huwh commented on PR #21496:
URL: https://github.com/apache/flink/pull/21496#issuecomment-1362759814
I have manually verified these tests below, with DeclarativeSlotManager and
DeclarativeSlotManager
* job with 2 parallism, flink cluster with 2 TaskManagers, each have 1
slot.
* TaskManager could released when idle timeoued.
* TaskManager could released when registered slots more than max.
* New JobManager/RM will use the previous TM when JobManager failover.
* New TaskManager will be requested when TaskManager terminated.
* registered taskmanager terminated
* allocated not registered taskmanager terminated
* released by RM because of reaching
resourcemanager.taskmanager-registration.timeout
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
