From e30160edc46c525bb0daa93cc46c04efb8ae55aa Mon Sep 17 00:00:00 2001 From: jerryshao Date: Tue, 8 Mar 2016 17:58:01 +0800 Subject: [PATCH] Fix yarn cluster fireAndForget behavior --- yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala index 36073de90d6af..6ca9669002980 100644 --- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala +++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala @@ -89,7 +89,7 @@ private[spark] class Client( } } } - private val fireAndForget = isClusterMode && sparkConf.get(WAIT_FOR_APP_COMPLETION) + private val fireAndForget = isClusterMode && !sparkConf.get(WAIT_FOR_APP_COMPLETION) private var appId: ApplicationId = null