diff --git a/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala b/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala index b147d8592c3d6..f15e6bc33fb41 100644 --- a/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala +++ b/core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala @@ -53,6 +53,7 @@ private[spark] class MesosExecutorBackend frameworkInfo: FrameworkInfo, slaveInfo: SlaveInfo) { + // Get num cores for this task from ExecutorInfo, created in MesosSchedulerBackend. val cpusPerTask = executorInfo.getResourcesList .find(_.getName == "cpus") .map(_.getScalar.getValue.toInt)