File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
yarn/src/main/scala/org/apache/spark/deploy/yarn Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -626,12 +626,11 @@ private[spark] class Client(
626626 if (fireAndForget) {
627627 val report = getApplicationReport(appId)
628628 val state = report.getYarnApplicationState
629+ logInfo(s " Application report for $appId (state: $state) " )
630+ logInfo(formatReportDetails(report))
629631 if (state == YarnApplicationState .FAILED || state == YarnApplicationState .KILLED ) {
630- logInfo(formatReportDetails(report))
631632 throw new SparkException (s " Application $appId finished with status: $state" )
632633 }
633- logInfo(s " Application report for $appId (state: $state) " )
634- logInfo(formatReportDetails(report))
635634 } else {
636635 val (yarnApplicationState, finalApplicationStatus) = monitorApplication(appId)
637636 if (yarnApplicationState == YarnApplicationState .FAILED ||
You can’t perform that action at this time.
0 commit comments