[GitHub] flink pull request #5307: [FLINK-8431] [mesos] Allow to specify # GPUs for T...

[eastcirclek]

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

    https://github.com/apache/flink/pull/5307#discussion_r162807064
  
    --- Diff: 
flink-mesos/src/main/java/org/apache/flink/mesos/scheduler/Offer.java ---
    @@ -81,11 +82,14 @@ public Offer(Protos.Offer offer) {
                }
                this.resources = Collections.unmodifiableList(resources);
     
    -           this.cpuCores = aggregateScalarResource(resourceMap, "cpus");
    -           this.memoryMB = aggregateScalarResource(resourceMap, "mem");
    -           this.networkMbps = aggregateScalarResource(resourceMap, 
"network");
    -           this.diskMB = aggregateScalarResource(resourceMap, "disk");
    -           this.portRanges = 
Collections.unmodifiableList(aggregateRangesResource(resourceMap, "ports"));
    +           Map<String, Double> aggregatedScalarResourceMap = 
scalarResourceMap.entrySet()
    +                   .stream()
    +                   .collect(Collectors.toMap(
    +                           e -> e.getKey(),
    +                           e -> e.getValue().stream().mapToDouble(r -> 
r.getScalar().getValue()).sum()
    +                   ));
    +           this.aggregatedScalarResourceMap = 
Collections.unmodifiableMap(aggregatedScalarResourceMap);
    --- End diff --
    
    thanks for the tip on Java 8 👍


---