You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2015/02/27 14:33:45 UTC
spark git commit: [SPARK-6059][Yarn] Add volatile to
ApplicationMaster's reporterThread and allocator
Repository: spark
Updated Branches:
refs/heads/master e747e9849 -> 57566d0af
[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 <zs...@gmail.com>
Closes #4814 from zsxwing/SPARK-6059 and squashes the following commits:
17d9386 [zsxwing] Add volatile to ApplicationMaster's reporterThread and allocator
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/57566d0a
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/57566d0a
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/57566d0a
Branch: refs/heads/master
Commit: 57566d0af3008982a1e24a763ed2f6a700b40f8f
Parents: e747e98
Author: zsxwing <zs...@gmail.com>
Authored: Fri Feb 27 13:33:39 2015 +0000
Committer: Sean Owen <so...@cloudera.com>
Committed: Fri Feb 27 13:33:39 2015 +0000
----------------------------------------------------------------------
.../scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/57566d0a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala
----------------------------------------------------------------------
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 796422b..e966bfb 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
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org