diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-02-27 13:33:39 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-02-27 13:33:39 +0000 |
| commit | 57566d0af3008982a1e24a763ed2f6a700b40f8f (patch) | |
| tree | 272721b6e12b18d274be65d685a6a11e3526737d /yarn | |
| parent | e747e98490f8ede23b0a9e0795e7445d0b597624 (diff) | |
| download | spark-57566d0af3008982a1e24a763ed2f6a700b40f8f.tar.gz spark-57566d0af3008982a1e24a763ed2f6a700b40f8f.tar.bz2 spark-57566d0af3008982a1e24a763ed2f6a700b40f8f.zip | |
[SPARK-6059][Yarn] Add volatile to ApplicationMaster's reporterThread and allocator
`ApplicationMaster.reporterThread` and `ApplicationMaster.allocator` are accessed in multiple threads, so they should be marked as `volatile`.
Author: zsxwing <zsxwing@gmail.com>
Closes #4814 from zsxwing/SPARK-6059 and squashes the following commits:
17d9386 [zsxwing] Add volatile to ApplicationMaster's reporterThread and allocator
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala index 796422bc25..e966bfba7b 100644 --- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala +++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala @@ -68,8 +68,8 @@ private[spark] class ApplicationMaster( @volatile private var finalMsg: String = "" @volatile private var userClassThread: Thread = _ - private var reporterThread: Thread = _ - private var allocator: YarnAllocator = _ + @volatile private var reporterThread: Thread = _ + @volatile private var allocator: YarnAllocator = _ // Fields used in client mode. private var actorSystem: ActorSystem = null |