[GitHub] flink pull request #5403: [WIP] Reschedule failed tasks to previous allocati...

[StefanRRichter]

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

    https://github.com/apache/flink/pull/5403#discussion_r170558995
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
 ---
    @@ -1518,11 +1469,27 @@ void clear() {
                                Collection<TaskManagerLocation> 
preferredLocations) {
     
                        final SlotRequestId requestId = new SlotRequestId();
    +                   Collection<AllocationID> previousAllocationIDs = 
Collections.emptyList();
    +
    +                   // try to extract previous allocation ids, if 
applicable, so that we can reschedule to the same slot
    +                   Execution execution = task.getTaskToExecute();
    --- End diff --
    
    👍 


---