diff options
author | Kousuke Saruta <sarutak@oss.nttdata.co.jp> | 2014-11-11 12:33:53 -0600 |
---|---|---|
committer | Thomas Graves <tgraves@apache.org> | 2014-11-11 12:33:53 -0600 |
commit | 7f3718842cc4025bb2ee2f5a3ec12efd100f6589 (patch) | |
tree | 3ac604505ddeb6b90596e70553c263d376d25ca8 /yarn | |
parent | f820b563d88f6a972c219d9340fe95110493fb87 (diff) | |
download | spark-7f3718842cc4025bb2ee2f5a3ec12efd100f6589.tar.gz spark-7f3718842cc4025bb2ee2f5a3ec12efd100f6589.tar.bz2 spark-7f3718842cc4025bb2ee2f5a3ec12efd100f6589.zip |
[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 <sarutak@oss.nttdata.co.jp>
Closes #3143 from sarutak/stopping-flag-volatile and squashes the following commits:
58fdcc9 [Kousuke Saruta] Marked stoppig flag as volatile
Diffstat (limited to 'yarn')
-rw-r--r-- | yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 f6f6dc5243..2923e6729c 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. |