Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/5114#discussion_r154998531 --- 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]) --- End diff -- If I recall correctly, The collection must be of a certain type.
---