[jira] [Created] (FLINK-1583) TaskManager reregistration in case of a restart

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

[jira] [Created] (FLINK-1583) TaskManager reregistration in case of a restart

Shang Yuanchun (Jira)
Till Rohrmann created FLINK-1583:
------------------------------------

             Summary: TaskManager reregistration in case of a restart
                 Key: FLINK-1583
                 URL: https://issues.apache.org/jira/browse/FLINK-1583
             Project: Flink
          Issue Type: Bug
            Reporter: Till Rohrmann


Currently, the {{InstanceManager}} identifies {{Instance}}s based on their {{InstanceConnectionInfo}}. In case of a restarted {{TaskManager}} which tries to register newly at the {{JobManager}}, the {{InstanceManager}} can mistake this {{TaskManager}} as already registered. This can lead to a corrupted state.

We should identify {{TaskManager}}s based on some ID to distinguish distinct registration attempts of a restarted {{TaskManager}}. This will improve the system's stability.



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