|
Change Variable Type slotsForGroup : Map<ResourceID,List<SharedSlot>> to slotsForGroup : LinkedHashMap<ResourceID,List<SharedSlot>> in method private getSlotForTaskInternal(groupId AbstractID, preferredLocations Iterable<TaskManagerLocation>, localOnly boolean) : Tuple2<SharedSlot,Locality> in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type entry : Map.Entry<AbstractID,Map<ResourceID,List<SharedSlot>>> to entry : Map.Entry<AbstractID,LinkedHashMap<ResourceID,List<SharedSlot>>> in method private removeSlotFromAllEntries(availableSlots Map<AbstractID,LinkedHashMap<ResourceID,List<SharedSlot>>>, slot SharedSlot) : void in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type entry : Map.Entry<AbstractID,Map<ResourceID,List<SharedSlot>>> to entry : Map.Entry<AbstractID,LinkedHashMap<ResourceID,List<SharedSlot>>> in method private addSharedSlotAndAllocateSubSlot(sharedSlot SharedSlot, locality Locality, groupId JobVertexID, constraint CoLocationConstraint) : SimpleSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |