|
Change Parameter Type locationPreferences : Iterable<Instance> to locationPreferences : Iterable<TaskManagerLocation> in method package getSlotForTask(constraint CoLocationConstraint, locationPreferences Iterable<TaskManagerLocation>) : SimpleSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Parameter Type location : Instance to location : ResourceID in method private removeFromMultiMap(map Map<ResourceID,List<SharedSlot>>, location ResourceID) : SharedSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Parameter Type map : Map<Instance,List<SharedSlot>> to map : Map<ResourceID,List<SharedSlot>> in method private putIntoMultiMap(map Map<ResourceID,List<SharedSlot>>, location ResourceID, slot SharedSlot) : void in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Parameter Type requestedLocations : Iterable<Instance> to requestedLocations : Iterable<TaskManagerLocation> in method protected getFreeSlotForTask(vertex ExecutionVertex, requestedLocations Iterable<TaskManagerLocation>, localOnly boolean) : SimpleSlot in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Parameter Type preferredLocations : Iterable<Instance> to preferredLocations : Iterable<TaskManagerLocation> 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 Parameter Type requestedLocations : Iterable<Instance> to requestedLocations : Iterable<TaskManagerLocation> in method protected getNewSlotForSharingGroup(vertex ExecutionVertex, requestedLocations Iterable<TaskManagerLocation>, groupAssignment SlotSharingGroupAssignment, constraint CoLocationConstraint, localOnly boolean) : SimpleSlot in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Parameter Type locationPreferences : Iterable<Instance> to locationPreferences : Iterable<TaskManagerLocation> in method package getSlotForTask(vertexID JobVertexID, locationPreferences Iterable<TaskManagerLocation>) : SimpleSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Parameter Type locations : Instance... to locations : TaskManagerLocation... in method public getTestVertexWithLocation(jid JobVertexID, taskIndex int, numTasks int, locations TaskManagerLocation...) : Execution in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerTestUtils |
From |
To |
|
Change Parameter Type instances : List<Instance> to instances : List<TaskManagerLocation> in method public setLocationConstraintHosts(instances List<TaskManagerLocation>) : void in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Parameter Type map : Map<Instance,List<SharedSlot>> to map : Map<ResourceID,List<SharedSlot>> in method private removeFromMultiMap(map Map<ResourceID,List<SharedSlot>>, location ResourceID) : SharedSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Parameter Type preferredLocations : Iterable<Instance> to preferredLocations : Iterable<TaskManagerLocation> in method public getTestVertex(preferredLocations Iterable<TaskManagerLocation>) : Execution in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerTestUtils |
From |
To |
|
Change Parameter Type map : Map<Instance,List<SharedSlot>> to map : Map<ResourceID,List<SharedSlot>> in method private pollFromMultiMap(map Map<ResourceID,List<SharedSlot>>) : SharedSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Parameter Type instances : Iterable<Instance> to locations : Iterable<TaskManagerLocation> in method private getHostnamesFromInstances(locations Iterable<TaskManagerLocation>) : String in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Parameter Type location : Instance to location : ResourceID in method private putIntoMultiMap(map Map<ResourceID,List<SharedSlot>>, location ResourceID, slot SharedSlot) : void in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Parameter Type availableSlots : Map<AbstractID,Map<Instance,List<SharedSlot>>> to availableSlots : Map<AbstractID,Map<ResourceID,List<SharedSlot>>> in method private removeSlotFromAllEntries(availableSlots Map<AbstractID,Map<ResourceID,List<SharedSlot>>>, slot SharedSlot) : void in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type available : Map<Instance,List<SharedSlot>> to available : Map<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 |
|
Change Variable Type loc : Instance to taskManager : ResourceID in method public scheduleWithIntermediateRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type locations : Iterable<Instance> to locations : Iterable<TaskManagerLocation> in method private scheduleTask(task ScheduledUnit, queueIfNoResource boolean) : Object in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type p : Pair<SharedSlot,Locality> to p : Tuple2<SharedSlot,Locality> in method package getSlotForTask(constraint CoLocationConstraint, locationPreferences Iterable<TaskManagerLocation>) : SimpleSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type p : Pair<SharedSlot,Locality> to p : Tuple2<SharedSlot,Locality> in method package getSlotForTask(vertexID JobVertexID, locationPreferences Iterable<TaskManagerLocation>) : SimpleSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type slotsForJid : Map<Instance,List<SharedSlot>> to slotsForJid : Map<ResourceID,List<SharedSlot>> in method package releaseSimpleSlot(simpleSlot SimpleSlot) : void in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type target2 : Instance to target2 : ResourceID in method public testScheduleWithConstraintAndSlotSharing() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type location : Instance to location : TaskManagerLocation 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 location : Instance to location : ResourceID in method private addSharedSlotAndAllocateSubSlot(sharedSlot SharedSlot, locality Locality, groupId JobVertexID, constraint CoLocationConstraint) : SimpleSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type slotsForGroup : Map<Instance,List<SharedSlot>> to slotsForGroup : Map<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 location : Instance to location : TaskManagerLocation in method package getSlotForTask(constraint CoLocationConstraint, locationPreferences Iterable<TaskManagerLocation>) : SimpleSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type i : Instance to loc : TaskManagerLocation in method private getHostnamesFromInstances(locations Iterable<TaskManagerLocation>) : String in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type target2 : Instance to target2 : ResourceID in method public testScheduleWithConstraint2() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type preferredLocations : Iterable<Instance> to preferredLocations : Iterable<TaskManagerLocation> in method private scheduleTask(task ScheduledUnit, queueIfNoResource boolean) : Object in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type iter : Iterator<Map.Entry<Instance,List<SharedSlot>>> to iter : Iterator<Map.Entry<ResourceID,List<SharedSlot>>> in method private pollFromMultiMap(map Map<ResourceID,List<SharedSlot>>) : SharedSlot in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type instance : Instance to taskManagerId : ResourceID in method private removeSlotFromAllEntries(availableSlots Map<AbstractID,Map<ResourceID,List<SharedSlot>>>, slot SharedSlot) : void in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type slotsForGroup : Map<Instance,List<SharedSlot>> to slotsForGroup : Map<ResourceID,List<SharedSlot>> in method private internalDisposeEmptySharedSlot(sharedSlot SharedSlot) : void in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type available : Map<Instance,List<SharedSlot>> to available : Map<ResourceID,List<SharedSlot>> in method public getNumberOfAvailableSlotsForGroup(groupId AbstractID) : int in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type target1 : Instance to target1 : ResourceID in method public testScheduleWithConstraint2() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type consumerInstance : Instance to consumerTaskManager : ResourceID in method package scheduleOrUpdateConsumers(allConsumers List<List<ExecutionEdge>>) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type target2 : Instance to target2 : ResourceID in method public testScheduleWithConstraint1() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type inputLocations : Set<Instance> to inputLocations : Set<TaskManagerLocation> in method public getPreferredLocations() : Iterable<TaskManagerLocation> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Variable Type entry : Map.Entry<AbstractID,Map<Instance,List<SharedSlot>>> to entry : Map.Entry<AbstractID,Map<ResourceID,List<SharedSlot>>> in method private removeSlotFromAllEntries(availableSlots Map<AbstractID,Map<ResourceID,List<SharedSlot>>>, slot SharedSlot) : void in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type target1 : Instance to target1 : ResourceID in method public testScheduleWithConstraintAndSlotSharing() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type target1 : Instance to target1 : ResourceID in method public testScheduleWithConstraint1() : void in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type locations : Set<Instance> to locations : Set<TaskManagerLocation> in method public getPreferredLocations() : Iterable<TaskManagerLocation> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Variable Type map : Map<Instance,List<SharedSlot>> to map : Map<ResourceID,List<SharedSlot>> in method private removeSlotFromAllEntries(availableSlots Map<AbstractID,Map<ResourceID,List<SharedSlot>>>, slot SharedSlot) : void in class org.apache.flink.runtime.instance.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type entry : Map.Entry<AbstractID,Map<Instance,List<SharedSlot>>> to entry : Map.Entry<AbstractID,Map<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 |
|
Change Variable Type constraintInstances : List<Instance> to constraintInstances : List<TaskManagerLocation> in method public getPreferredLocations() : Iterable<TaskManagerLocation> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |