Skip to content

Commit 28752d6

Browse files
catch the throwed exception
1 parent 1b49999 commit 28752d6

File tree

1 file changed

+3
-0
lines changed
  • yarn/src/main/scala/org/apache/spark/deploy/yarn

1 file changed

+3
-0
lines changed

yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -771,6 +771,9 @@ private[spark] class Client(
771771
case e: ApplicationNotFoundException =>
772772
logError(s"Application $appId not found.")
773773
return (YarnApplicationState.KILLED, FinalApplicationStatus.KILLED)
774+
case e: Exception =>
775+
logError(s"Failed to contanct YARN for application $appId.", e)
776+
return (YarnApplicationState.FAILED, FinalApplicationStatus.FAILED)
774777
}
775778
val state = report.getYarnApplicationState
776779

0 commit comments

Comments
 (0)