Repository: spark Updated Branches: refs/heads/master 253a07e43 -> 97ccc63f7
[SPARK-21585] Application Master marking application status as Failed for Client Mode The fix deployed for SPARK-21541 resulted in the Application Master to set the final status of a spark application as Failed for the client mode as the flag 'registered' was not being set to true for client mode. So, in order to fix the issue, I have set the flag 'registered' as true in client mode on successfully registering Application Master. ## How was this patch tested? Tested the patch manually. Before: <img width="1275" alt="screen shot-before2" src="https://user-images.githubusercontent.com/22228190/28799641-02b5ed78-760f-11e7-9eb0-bf8407dad0ad.png"> After: <img width="1221" alt="screen shot-after2" src="https://user-images.githubusercontent.com/22228190/28799646-0ac9ef14-760f-11e7-8bf5-9dfd743d0f2f.png"> Please review http://spark.apache.org/contributing.html before opening a pull request. Author: pgandhi <pgan...@yahoo-inc.com> Author: pgandhi999 <parthkgand...@gmail.com> Closes #18788 from pgandhi999/SPARK-21585. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/97ccc63f Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/97ccc63f Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/97ccc63f Branch: refs/heads/master Commit: 97ccc63f7d377e43d9ae989d164e9f50788c66a6 Parents: 253a07e Author: pgandhi <pgan...@yahoo-inc.com> Authored: Tue Aug 1 08:42:24 2017 -0500 Committer: Tom Graves <tgra...@yahoo-inc.com> Committed: Tue Aug 1 08:42:24 2017 -0500 ---------------------------------------------------------------------- .../main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/97ccc63f/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala ---------------------------------------------------------------------- diff --git a/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala index ca6a3ef..0387b44 100644 --- a/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala +++ b/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala @@ -474,6 +474,7 @@ private[spark] class ApplicationMaster( addAmIpFilter() registerAM(sparkConf, rpcEnv, driverRef, sparkConf.getOption("spark.driver.appUIAddress"), securityMgr) + registered = true // In client mode the actor will stop the reporter thread. reporterThread.join() --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org