Github user EronWright commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5114#discussion_r155026726
  
    --- Diff: 
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/LaunchCoordinator.scala
 ---
    @@ -185,7 +189,7 @@ class LaunchCoordinator(
             // process the assignments into a set of operations (reserve 
and/or launch)
             val slaveId = assignments.getLeasesUsed.get(0).getOffer.getSlaveId
             val offerIds = 
assignments.getLeasesUsed.asScala.map(_.getOffer.getId)
    -        val operations = processAssignments(slaveId, assignments, 
remaining.toMap)
    +        val operations = processAssignments(LOG, slaveId, assignments, 
remaining.toMap)
    --- End diff --
    
    The issue is that the class extends `Actor` which has a `log` field that we 
don't intend to use.  I will use `log` in `processAssignments`.


---

Reply via email to