Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/5114#discussion_r154999162 --- Diff: flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/LaunchCoordinator.scala --- @@ -148,14 +149,17 @@ class LaunchCoordinator( case Event(offers: ResourceOffers, data: GatherData) => val leases = offers.offers().asScala.map( - new VMLeaseObject(_).asInstanceOf[VirtualMachineLease]) + new Offer(_).asInstanceOf[VirtualMachineLease]) if(LOG.isInfoEnabled) { val (cpus, mem) = leases.foldLeft((0.0,0.0)) { (z,o) => (z._1 + o.cpuCores(), z._2 + o.memoryMB()) } LOG.info(s"Received offer(s) of $mem MB, $cpus cpus:") for(l <- leases) { - LOG.info(s" ${l.getId} from ${l.hostname()} of ${l.memoryMB()} MB, ${l.cpuCores()} cpus") + val reservations = l.asInstanceOf[Offer].getResources.asScala.map(_.getRole).toSet --- End diff -- (see above)
---