flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kurt Young (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4807) ResourceManager clean up JobManager's registration
Date Wed, 12 Oct 2016 01:29:20 GMT
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)

Mime
View raw message