[
https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479296#comment-16479296
]
ASF GitHub Bot commented on FLINK-6160:
---------------------------------------
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189017088
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -947,6 +964,36 @@ private void closeResourceManagerConnection(Exception
cause) {
resourceManagerConnection.close();
resourceManagerConnection = null;
}
+
+ startRegistrationTimeout();
--- End diff --
The problem is that we want this timeout to start whenever the
`TaskExecutor` loses its connection to the RM and that's when we close the RM
connection. This also covers the case, where we don't know the RM address (e.g.
if the RM loses leadership).
> Retry JobManager/ResourceManager connection in case of timeout
> ---------------------------------------------------------------
>
> Key: FLINK-6160
> URL: https://issues.apache.org/jira/browse/FLINK-6160
> Project: Flink
> Issue Type: Sub-task
> Components: Distributed Coordination
> Affects Versions: 1.3.0, 1.5.0, 1.6.0
> Reporter: Till Rohrmann
> Assignee: Till Rohrmann
> Priority: Blocker
> Labels: flip-6
> Fix For: 1.5.0
>
>
> In case of a heartbeat timeout, the {{TaskExecutor}} closes the connection to
> the remote component. Furthermore, it assumes that the component has actually
> failed and, thus, it will only start trying to connect to the component if it
> is notified about a new leader address and leader session id. This is
> brittle, because the heartbeat could also time out without the component
> having crashed. Thus, we should add an automatic retry to the latest known
> leader address information in case of a timeout.
> *Acceptance criteria:*
> - The registration should be retried until a time limit expires after which
> the {{TaskExecutor}} terminates.
> - If the registration is declined ({{RegistrationResponse.Decline}}), the
> {{TaskExecutor}} should terminate.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
