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 /yarn/2.2 | |
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.
Diffstat (limited to 'yarn/2.2')
-rw-r--r-- | yarn/2.2/src/main/scala/org/apache/spark/deploy/yarn/WorkerLauncher.scala | 2 |
1 files changed, 2 insertions, 0 deletions
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]) } |