Description
Should add diagnostics in DAGAppMaster when recovery error happens, otherwise AM is shutdown and the next dag submission will just throw SessionNotRunningException which would confuse users.
if (this.historyEventHandler.hasRecoveryFailed()) { LOG.warn("Recovery had a fatal error, shutting down session after" + " DAG completion"); sessionStopped.set(true); }