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:34:02 -0600 |
| commit | ec0d89bc93f3a69a844d4b133bf185ee24048726 (patch) | |
| tree | 3e805503c39b46557714fbdb92187afed70a1172 /yarn/common | |
| parent | 8f7e80f30bd34897963334d0245c0ea6fccd6182 (diff) | |
| download | spark-ec0d89bc93f3a69a844d4b133bf185ee24048726.tar.gz spark-ec0d89bc93f3a69a844d4b133bf185ee24048726.tar.bz2 spark-ec0d89bc93f3a69a844d4b133bf185ee24048726.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
(cherry picked from commit 7f3718842cc4025bb2ee2f5a3ec12efd100f6589)
Signed-off-by: Thomas Graves <tgraves@apache.org>
Diffstat (limited to 'yarn/common')
| -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. |