Till Rohrmann created FLINK-8673:
------------------------------------
Summary: Don't let JobManagerRunner shut down itself
Key: FLINK-8673
URL: https://issues.apache.org/jira/browse/FLINK-8673
Project: Flink
Issue Type: Improvement
Components: Distributed Coordination
Affects Versions: 1.5.0
Reporter: Till Rohrmann
Assignee: Till Rohrmann
Fix For: 1.5.0
Currently, the {{JobManagerRunner}} is allowed to shut down itself in case of a
job completion. This, however, can cause problems when the {{Dispatcher}}
receives a request for a {{JobMaster}}. If the {{Dispatcher}} is not told about
the shut down of the {{JobMaster}} then it might still try to send requests to
it. This will lead to time outs.
It would be better to simply let the {{JobManagerRunner}} not shut down itself
and defer it to the owner (the {{Dispatcher}}). We can do this by listening on
the {{JobManagerRunner#resultFuture}} which is completed by the
{{JobManagerRunner}} in case of a successful job completion or a failure. That
way we could also get rid of the {{OnCompletionActions}} and the
{{FatalErrorHandler}}.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
