[jira] [Created] (FLINK-4807) ResourceManager clean up JobManager's registration

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-4807) ResourceManager clean up JobManager's registration

Shang Yuanchun (Jira)
Kurt Young created FLINK-4807:
---------------------------------

             Summary: ResourceManager clean up JobManager's registration
                 Key: FLINK-4807
                 URL: https://issues.apache.org/jira/browse/FLINK-4807
             Project: Flink
          Issue Type: Sub-task
            Reporter: Kurt Young


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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)