Fix a change that was lost during merge

2013-12-29 18:15:46 -05:00 · 2013-12-29 18:15:46 -05:00 · 1ee7f5aee4
parent 0bd1900cbc
commit 1ee7f5aee4
1 changed files with 2 additions and 1 deletions
--- a/core/src/main/scala/org/apache/spark/scheduler/local/LocalBackend.scala
+++ b/core/src/main/scala/org/apache/spark/scheduler/local/LocalBackend.scala
@ -47,7 +47,8 @@ private[spark] class LocalActor(
  private val localExecutorId = "localhost"
  private val localExecutorHostname = "localhost"

-  val executor = new Executor(localExecutorId, localExecutorHostname, Seq.empty, isLocal = true)
+  val executor = new Executor(
+    localExecutorId, localExecutorHostname, scheduler.conf.getAll, isLocal = true)

  def receive = {
    case ReviveOffers =>