aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2013-12-16 22:10:55 -0800
committerPatrick Wendell <pwendell@gmail.com>2013-12-16 22:10:55 -0800
commit10c0ffa1eb23c6190f460be224ea555573458980 (patch)
treeb30e8f222e936f8a0ef930f7336b3b973385da58
parentc1c0f8099f4559ff3ff9982878da6cd36d198ba0 (diff)
downloadspark-10c0ffa1eb23c6190f460be224ea555573458980.tar.gz
spark-10c0ffa1eb23c6190f460be224ea555573458980.tar.bz2
spark-10c0ffa1eb23c6190f460be224ea555573458980.zip
One other fix
-rw-r--r--new-yarn/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala b/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala
index dca389d64e..bc31bb2eb0 100644
--- a/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala
+++ b/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala
@@ -54,7 +54,7 @@ class WorkerLauncher(args: ApplicationMasterArguments, conf: Configuration) exte
// This actor just working as a monitor to watch on Driver Actor.
class MonitorActor(driverUrl: String) extends Actor {
- var driver: ActorRef = null
+ var driver: ActorSelection = null
override def preStart() {
logInfo("Listen to driver: " + driverUrl)