Till Rohrmann created FLINK-11843:
-------------------------------------
Summary: Dispatcher fails to recover jobs if leader change happens
during JobManagerRunner termination
Key: FLINK-11843
URL: https://issues.apache.org/jira/browse/FLINK-11843
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 1.7.2, 1.8.0
Reporter: Till Rohrmann
The {{Dispatcher}} fails to recover jobs if a leader change happens during the
{{JobManagerRunner}} termination of the previous run. The problem is that we
schedule the start future of the recovered {{JobGraph}} using the
{{MainThreadExecutor}} and additionally require that this future is completed
before any other recovery operation from a subsequent leadership session is
executed. If now the leadership changes, the {{MainThreadExecutor}} will be
invalidated and the scheduled future will never be completed.
The relevant ML thread:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/1-7-1-job-stuck-in-suspended-state-td26439.html
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
