We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4770f6e commit 7045e77Copy full SHA for 7045e77
core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala
@@ -53,6 +53,7 @@ private[spark] class MesosExecutorBackend
53
frameworkInfo: FrameworkInfo,
54
slaveInfo: SlaveInfo) {
55
56
+ // Get num cores for this task from ExecutorInfo, created in MesosSchedulerBackend.
57
val cpusPerTask = executorInfo.getResourcesList
58
.find(_.getName == "cpus")
59
.map(_.getScalar.getValue.toInt)
0 commit comments