diff options
| author | Raymond Liu <raymond.liu@intel.com> | 2013-12-17 16:08:12 +0800 |
|---|---|---|
| committer | Raymond Liu <raymond.liu@intel.com> | 2014-01-03 12:14:37 +0800 |
| commit | ad60710010c4f1cefaab443f8c5e01f495ccaa60 (patch) | |
| tree | f7d70d60fa99ebb5cdd4211b979794ffd5293a34 | |
| parent | dd6d347f4f9bee6f7509fffe07a1a2d74803f783 (diff) | |
| download | spark-ad60710010c4f1cefaab443f8c5e01f495ccaa60.tar.gz spark-ad60710010c4f1cefaab443f8c5e01f495ccaa60.tar.bz2 spark-ad60710010c4f1cefaab443f8c5e01f495ccaa60.zip | |
Need to send dummy hello message to actually estabilish akka connection.
| -rw-r--r-- | yarn/2.0/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala | 2 | ||||
| -rw-r--r-- | yarn/2.2/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala | 2 |
2 files changed, 4 insertions, 0 deletions
diff --git a/yarn/2.0/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala b/yarn/2.0/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala index 1ef099aceb..e64530702c 100644 --- a/yarn/2.0/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala +++ b/yarn/2.0/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala @@ -60,6 +60,8 @@ class WorkerLauncher(args: ApplicationMasterArguments, conf: Configuration) exte override def preStart() { logInfo("Listen to driver: " + driverUrl) driver = context.actorSelection(driverUrl) + // Send a hello message thus the connection is actually established, thus we can monitor Lifecycle Events. + driver ! "Hello" context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent]) } diff --git a/yarn/2.2/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala b/yarn/2.2/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala index 191ef798d7..4d9cca0766 100644 --- a/yarn/2.2/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala +++ b/yarn/2.2/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala @@ -61,6 +61,8 @@ class WorkerLauncher(args: ApplicationMasterArguments, conf: Configuration) exte override def preStart() { logInfo("Listen to driver: " + driverUrl) driver = context.actorSelection(driverUrl) + // Send a hello message thus the connection is actually established, thus we can monitor Lifecycle Events. + driver ! "Hello" context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent]) } |