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

    https://github.com/apache/storm/pull/2764#discussion_r208703156
  
    --- Diff: 
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
    @@ -780,15 +870,15 @@ private static int numUsedWorkers(SchedulerAssignment 
assignment) {
                 key.add(ni.get_node());
                 key.add(ni.get_port_iterator().next());
                 List<List<Long>> value = new ArrayList<>(entry.getValue());
    -            value.sort((a, b) -> a.get(0).compareTo(b.get(0)));
    +            value.sort(Comparator.comparing(a -> a.get(0)));
    --- End diff --
    
    Neat, didn't know about this method.


---

Reply via email to