From 24f8220dc8a0671df7ee32b3eb193120ca316878 Mon Sep 17 00:00:00 2001
From: Patrick Wendell <pwendell@gmail.com>
Date: Mon, 16 Dec 2013 13:04:07 -0800
Subject: [PATCH] Removing extra code in new yarn
---
.../main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala | 1 -
1 file changed, 1 deletion(-)
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 11da1c4e73..ac519fc99c 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
@@ -59,7 +59,6 @@ class WorkerLauncher(args: ApplicationMasterArguments, conf: Configuration) exte
override def preStart() {
logInfo("Listen to driver: " + driverUrl)
driver = context.actorFor(driverUrl)
- driver ! "hello"
context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent])
}
--
GitLab