diff options
| author | Kousuke Saruta <sarutak@oss.nttdata.co.jp> | 2014-09-17 16:52:27 -0700 |
|---|---|---|
| committer | Andrew Or <andrewor14@gmail.com> | 2014-09-17 16:52:27 -0700 |
| commit | 1147973f1c7713013c7c0ca414482b511a730475 (patch) | |
| tree | ba50ba4bb0d2e109a361f2d3ccb642ab7d96dee3 | |
| parent | 6688a266f2cb84c2d43b8e4d27f710718c4cc4a0 (diff) | |
| download | spark-1147973f1c7713013c7c0ca414482b511a730475.tar.gz spark-1147973f1c7713013c7c0ca414482b511a730475.tar.bz2 spark-1147973f1c7713013c7c0ca414482b511a730475.zip | |
[SPARK-3567] appId field in SparkDeploySchedulerBackend should be volatile
Author: Kousuke Saruta <sarutak@oss.nttdata.co.jp>
Closes #2428 from sarutak/appid-volatile-modification and squashes the following commits:
c7d890d [Kousuke Saruta] Added volatile modifier to appId field in SparkDeploySchedulerBackend
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala index 2f45d192e1..5c5ecc8434 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala @@ -34,7 +34,7 @@ private[spark] class SparkDeploySchedulerBackend( var client: AppClient = null var stopping = false var shutdownCallback : (SparkDeploySchedulerBackend) => Unit = _ - var appId: String = _ + @volatile var appId: String = _ val registrationLock = new Object() var registrationDone = false |