Github user skonto commented on a diff in the pull request:
https://github.com/apache/spark/pull/19390#discussion_r147087477
--- Diff:
resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerUtils.scala
---
@@ -451,15 +465,20 @@ trait MesosSchedulerUtils extends Logging {
}
/** Creates a mesos resource for a specific port number. */
- private def createResourcesFromPorts(portsAndRoles: List[(Long,
String)]) : List[Resource] = {
- portsAndRoles.flatMap{ case (port, role) =>
- createMesosPortResource(List((port, port)), Some(role))}
+ private def createResourcesFromPorts(
+ portsAndResourcesInfo: List[(Long, (String, AllocationInfo,
Option[ReservationInfo]))])
+ : List[Resource] = {
+ portsAndResourcesInfo.flatMap{ case (port, rInfo) =>
+ createMesosPortResource(List((port, port)), Option(rInfo._1),
--- End diff --
Sure.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
