diff options
| author | Prashant Sharma <scrapcodes@gmail.com> | 2013-09-22 08:20:12 +0530 |
|---|---|---|
| committer | Prashant Sharma <scrapcodes@gmail.com> | 2013-09-22 08:20:12 +0530 |
| commit | 276c37a51c9a6188dbbe02754935540ace338dd1 (patch) | |
| tree | 42f08c5255bf7cb58e06580bd1812573bf487dbc /yarn | |
| parent | 69fd42aee3f3fed8dbb5f2933413cbf31cac74d1 (diff) | |
| download | spark-276c37a51c9a6188dbbe02754935540ace338dd1.tar.gz spark-276c37a51c9a6188dbbe02754935540ace338dd1.tar.bz2 spark-276c37a51c9a6188dbbe02754935540ace338dd1.zip | |
Akka 2.2 migration
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala index 6d6ef149cc..d222f412a0 100644 --- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala +++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala @@ -209,7 +209,7 @@ private[yarn] class YarnAllocationHandler(val conf: Configuration, val resourceM else { // deallocate + allocate can result in reusing id's wrongly - so use a different counter (workerIdCounter) val workerId = workerIdCounter.incrementAndGet().toString - val driverUrl = "akka://spark@%s:%s/user/%s".format( + val driverUrl = "akka.tcp://spark@%s:%s/user/%s".format( System.getProperty("spark.driver.host"), System.getProperty("spark.driver.port"), StandaloneSchedulerBackend.ACTOR_NAME) |