You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by tg...@apache.org on 2014/11/11 19:33:55 UTC
spark git commit: [SPARK-4282][YARN] Stopping flag in
YarnClientSchedulerBackend should be volatile
Repository: spark
Updated Branches:
refs/heads/master f820b563d -> 7f3718842
[SPARK-4282][YARN] Stopping flag in YarnClientSchedulerBackend should be volatile
In YarnClientSchedulerBackend, a variable "stopping" is used as a flag and it's accessed by some threads so it should be volatile.
Author: Kousuke Saruta <sa...@oss.nttdata.co.jp>
Closes #3143 from sarutak/stopping-flag-volatile and squashes the following commits:
58fdcc9 [Kousuke Saruta] Marked stoppig flag as volatile
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/7f371884
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/7f371884
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/7f371884
Branch: refs/heads/master
Commit: 7f3718842cc4025bb2ee2f5a3ec12efd100f6589
Parents: f820b56
Author: Kousuke Saruta <sa...@oss.nttdata.co.jp>
Authored: Tue Nov 11 12:33:53 2014 -0600
Committer: Thomas Graves <tg...@apache.org>
Committed: Tue Nov 11 12:33:53 2014 -0600
----------------------------------------------------------------------
.../spark/scheduler/cluster/YarnClientSchedulerBackend.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/7f371884/yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala
----------------------------------------------------------------------
diff --git a/yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala b/yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala
index f6f6dc5..2923e67 100644
--- a/yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala
+++ b/yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala
@@ -33,7 +33,7 @@ private[spark] class YarnClientSchedulerBackend(
private var client: Client = null
private var appId: ApplicationId = null
- private var stopping: Boolean = false
+ @volatile private var stopping: Boolean = false
/**
* Create a Yarn client to submit an application to the ResourceManager.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org