Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
None
-
None
Description
When RM received a JM's registration, it will record it either with some leaderid or leadership listener. We should make sure the finished / failed JM can properly unregister itself with RM.
We can make it happen by doing these two things:
1. If JM finds out job reaches a terminate state(either success or fail), it should send an unregistration request to RM.
2. If (1) does not happen for various reasons, RM can rely on the heartbeat manager to find out timeout JM and clear it up.
Attachments
Issue Links
- duplicates
-
FLINK-4853 Clean up JobManager registration at the ResourceManager
- Closed