Skip to content

Commit 1e67234

Browse files
mateizrxin
authored andcommitted
Merge pull request alteryx#65 from tgravescs/fixYarn
Fix yarn build Fix the yarn build after renaming StandAloneX to CoarseGrainedX from pull request 34. (cherry picked from commit f9973ca) Signed-off-by: Reynold Xin <rxin@apache.org>
1 parent d0c9d41 commit 1e67234

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocationHandler.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import org.apache.spark.util.Utils
2222
import org.apache.spark.scheduler.SplitInfo
2323
import scala.collection
2424
import org.apache.hadoop.yarn.api.records.{AMResponse, ApplicationAttemptId, ContainerId, Priority, Resource, ResourceRequest, ContainerStatus, Container}
25-
import org.apache.spark.scheduler.cluster.{ClusterScheduler, StandaloneSchedulerBackend}
25+
import org.apache.spark.scheduler.cluster.{ClusterScheduler, CoarseGrainedSchedulerBackend}
2626
import org.apache.hadoop.yarn.api.protocolrecords.{AllocateRequest, AllocateResponse}
2727
import org.apache.hadoop.yarn.util.{RackResolver, Records}
2828
import java.util.concurrent.{CopyOnWriteArrayList, ConcurrentHashMap}
@@ -211,7 +211,7 @@ private[yarn] class YarnAllocationHandler(val conf: Configuration, val resourceM
211211
val workerId = workerIdCounter.incrementAndGet().toString
212212
val driverUrl = "akka://spark@%s:%s/user/%s".format(
213213
System.getProperty("spark.driver.host"), System.getProperty("spark.driver.port"),
214-
StandaloneSchedulerBackend.ACTOR_NAME)
214+
CoarseGrainedSchedulerBackend.ACTOR_NAME)
215215

216216
logInfo("launching container on " + containerId + " host " + workerHostname)
217217
// just to be safe, simply remove it from pendingReleaseContainers. Should not be there, but ..

0 commit comments

Comments
 (0)