Github user skonto commented on a diff in the pull request:
https://github.com/apache/spark/pull/21516#discussion_r194688618
--- Diff:
resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosCoarseGrainedSchedulerBackend.scala
---
@@ -796,6 +811,38 @@ private[spark] class
MesosCoarseGrainedSchedulerBackend(
None
}
}
+
+ // Calls used for metrics polling, see MesosCoarseGrainedSchedulerSource:
+
+ def getCoresUsed(): Double = totalCoresAcquired
--- End diff --
Are there any issues with concurrency here. When
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
