|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public testScheduleOutOfOrder() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type toRelease : Set<AllocatedSlot> to toRelease : Set<SimpleSlot> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s5_2 : AllocatedSlot to s5_2 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public toJson(vertex ExecutionVertex) : String in class org.apache.flink.runtime.jobmanager.web.JsonFactory |
From |
To |
|
Change Variable Type s31 : AllocatedSlot to s31 : SimpleSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4_3 : AllocatedSlot to s4_3 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slotFromGroup : SubSlot to slotFromGroup : SimpleSlot in method private scheduleTask(task ScheduledUnit, queueIfNoResource boolean) : Object in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type slotsAfter : List<AllocatedSlot> to slotsAfter : List<SimpleSlot> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s8 : AllocatedSlot to s8 : SimpleSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public scheduleWithIntermediateRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public scheduleImmediatelyWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s5 : AllocatedSlot to s5 : SimpleSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testLocalizedAssignment1() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4_2 : AllocatedSlot to s4_2 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sC1 : AllocatedSlot to sC1 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public testLocalizedAssignment2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sA1 : AllocatedSlot to sA1 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s24 : AllocatedSlot to s24 : SimpleSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot_1_4 : AllocatedSlot to slot_1_4 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_2 : AllocatedSlot to s2_2 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testSlotReleasedInBetween() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot1 : AllocatedSlot to slot1 : SimpleSlot in method public testAllocatingAndCancellingSlots() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public testSlotReleasedInBetween() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s3_3 : AllocatedSlot to s3_3 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_1_1 : AllocatedSlot to slot_1_1 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type syncSlot : AllocatedSlot to syncSlot : SimpleSlot in method public setSync() : void in class org.apache.flink.runtime.jobmanager.scheduler.SlotAllocationFutureTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testDeployCall() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexDeploymentTest |
From |
To |
|
Change Variable Type s4_1 : AllocatedSlot to s4_1 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sx : AllocatedSlot to sx : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_2 : AllocatedSlot to s2_2 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3_2 : AllocatedSlot to s3_2 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s22 : AllocatedSlot to s22 : SimpleSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot2 : AllocatedSlot to slot2 : SimpleSlot in method public testCancelAllSlots() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_3 : AllocatedSlot to s1_3 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type slot2 : AllocatedSlot to slot2 : SimpleSlot in method public testAllocatingAndCancellingSlots() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_3 : AllocatedSlot to s2_3 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3_1 : AllocatedSlot to s3_1 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public scheduleWithReleaseNoResource() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4_2 : AllocatedSlot to s4_2 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type consumerSlot : AllocatedSlot to consumerSlot : SimpleSlot in method package scheduleOrUpdateConsumers(consumers List<List<ExecutionEdge>>) : boolean in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testLocalizedAssignment1() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_2 : AllocatedSlot to s2_2 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public nonColocationFollowsCoLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type subslot : SubSlot to subSlot : SimpleSlot in method public addSharedSlotAndAllocateSubSlot(sharedSlot SharedSlot, locality Locality, groupId AbstractID, constraint CoLocationConstraint) : SimpleSlot in class org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type sSolo : AllocatedSlot to sSolo : SimpleSlot in method public scheduleWithIntermediateRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testBuildDeploymentDescriptor() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type slot3 : AllocatedSlot to slot3 : SimpleSlot in method public testAllocatingAndCancellingSlots() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type s1_3 : AllocatedSlot to s1_3 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4_1 : AllocatedSlot to s4_1 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method private sendCancelRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s2_1 : AllocatedSlot to s2_1 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_2_2 : AllocatedSlot to slot_2_2 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_4_2 : AllocatedSlot to slot_4_2 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sB2 : AllocatedSlot to sB2 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3_0 : AllocatedSlot to s3_0 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testDeployFailedAsynchronously() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexDeploymentTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testDeployWithSynchronousAnswer() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexDeploymentTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testConcurrentAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_2 : AllocatedSlot to s1_2 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_1 : AllocatedSlot to s2_1 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_2 : AllocatedSlot to s2_2 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot4 : AllocatedSlot to slot4 : SimpleSlot in method public testAllocatingAndCancellingSlots() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type s11 : AllocatedSlot to s11 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public testScheduleOutOfOrder() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testScheduleOutOfOrder() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s1_1 : AllocatedSlot to s1_1 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testActionsWhileCancelling() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s2_3 : AllocatedSlot to s2_3 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testInvalidActions() : void in class org.apache.flink.runtime.jobmanager.scheduler.SlotAllocationFutureTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s3_3 : AllocatedSlot to s3_3 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type producerSlot : AllocatedSlot to producerSlot : SimpleSlot in method public fromEdge(edge ExecutionEdge, consumerSlot SimpleSlot) : PartitionInfo in class org.apache.flink.runtime.deployment.PartitionInfo |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public scheduleImmediatelyWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public testLocalizedAssignment1() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public scheduleForExecution(scheduler Scheduler, queued boolean) : boolean in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type sC0 : AllocatedSlot to sC0 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type toUse : SubSlot to toUse : SimpleSlot in method private scheduleTask(task ScheduledUnit, queueIfNoResource boolean) : Object in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testSlotReleasedWhenScheduledQueued() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexSchedulingTest |
From |
To |
|
Change Variable Type newSlot : AllocatedSlot to newSlot : SimpleSlot in method private handleNewSlot() : void in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type slot3 : AllocatedSlot to slot3 : SimpleSlot in method public testInstanceDies() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type s34 : AllocatedSlot to s34 : SimpleSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testFailExternallyDuringDeploy() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexDeploymentTest |
From |
To |
|
Change Variable Type slot : SubSlot to slot : SimpleSlot in method public getSlotForTask(vertex ExecutionVertex) : SimpleSlot in class org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type slot_1_3 : AllocatedSlot to slot_1_3 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s9 : AllocatedSlot to s9 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type sourceSlot : AllocatedSlot to sourceSlot : SimpleSlot in method public getPreferredLocations() : Iterable<Instance> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Variable Type s2_2 : AllocatedSlot to s2_2 : SimpleSlot in method public scheduleImmediatelyWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type newSlot : AllocatedSlot to newSlot : SimpleSlot in method private scheduleTask(task ScheduledUnit, queueIfNoResource boolean) : Object in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type s32 : AllocatedSlot to s32 : SimpleSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4_2 : AllocatedSlot to s4_2 : SimpleSlot in method public scheduleImmediatelyWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s8 : AllocatedSlot to s8 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public scheduleImmediatelyWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s5 : AllocatedSlot to s5 : SimpleSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public testLocalizedAssignment1() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s7 : AllocatedSlot to s7 : SimpleSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s6 : AllocatedSlot to s6 : SimpleSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public nonColocationFollowsCoLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public setWithAction() : void in class org.apache.flink.runtime.jobmanager.scheduler.SlotAllocationFutureTest |
From |
To |
|
Change Variable Type iter : Iterator<AllocatedSlot> to iter : Iterator<SimpleSlot> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s7 : AllocatedSlot to s7 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot1 : AllocatedSlot to slot1 : SimpleSlot in method public testCancelAllSlots() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type s1_0 : AllocatedSlot to s1_0 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testReleaseCancelsVertex() : void in class org.apache.flink.runtime.instance.AllocatedSlotTest |
From |
To |
|
Change Variable Type s4_0 : AllocatedSlot to s4_0 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot2 : AllocatedSlot to slot2 : SimpleSlot in method public testInstanceDies() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : Slot in method public cancelAndReleaseAllSlots() : void in class org.apache.flink.runtime.instance.Instance |
From |
To |
|
Change Variable Type sB1 : AllocatedSlot to sB1 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type retrieved : AllocatedSlot to retrieved : SimpleSlot in method public setSync() : void in class org.apache.flink.runtime.jobmanager.scheduler.SlotAllocationFutureTest |
From |
To |
|
Change Variable Type slot_2_4 : AllocatedSlot to slot_2_4 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public scheduleWithIntermediateRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testSlotReleasedInBetween() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot_4_4 : AllocatedSlot to slot_4_4 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s6 : AllocatedSlot to s6 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public testSlotReleasedInBetween() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot_2_1 : AllocatedSlot to slot_2_1 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s5 : AllocatedSlot to s5 : SimpleSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type slot_4_1 : AllocatedSlot to slot_4_1 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s23 : AllocatedSlot to s23 : SimpleSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type sub : SubSlot to slot : SimpleSlot in method public answer(invocation InvocationOnMock) : Boolean in class org.apache.flink.runtime.jobmanager.scheduler.SharedSlotsTest.createAndRelease.releaseSimpleSlot.when.doAnswer |
From |
To |
|
Change Variable Type s5_2 : AllocatedSlot to s5_2 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type single : AllocatedSlot to single : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testLocalizedAssignment2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4_3 : AllocatedSlot to s4_3 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s6 : AllocatedSlot to s6 : SimpleSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testSetExecutionVertex() : void in class org.apache.flink.runtime.instance.AllocatedSlotTest |
From |
To |
|
Change Variable Type s5 : AllocatedSlot to s5 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testScheduleOutOfOrder() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s3_2 : AllocatedSlot to s3_2 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_1 : AllocatedSlot to s1_1 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testScheduleOrDeployAfterCancel() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type sNew : AllocatedSlot to sNew : SimpleSlot in method public scheduleWithIntermediateRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public run() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest.testConcurrentAllocateAndRelease.deploy1 |
From |
To |
|
Change Variable Type s21 : AllocatedSlot to s21 : SimpleSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public run() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest.testConcurrentAllocateAndRelease.deploy2 |
From |
To |
|
Change Variable Type s5 : AllocatedSlot to s5 : SimpleSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testScheduleToRunning() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexSchedulingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testAccumulatedStateFinished() : void in class org.apache.flink.runtime.executiongraph.ExecutionStateProgressTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testCancelCallFails() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type s2_0 : AllocatedSlot to s2_0 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slots : List<AllocatedSlot> to slots : List<SimpleSlot> in method public testScheduleWithDyingInstances() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type slot1 : AllocatedSlot to slot1 : SimpleSlot in method public testInstanceDies() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type s3_2 : AllocatedSlot to s3_2 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s6 : AllocatedSlot to s6 : SimpleSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_1 : AllocatedSlot to s1_1 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot3 : AllocatedSlot to slot3 : SimpleSlot in method public testCancelAllSlots() : void in class org.apache.flink.runtime.instance.InstanceTest |
From |
To |
|
Change Variable Type slot_1_2 : AllocatedSlot to slot_1_2 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s5 : AllocatedSlot to s5 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testStateTransitions() : void in class org.apache.flink.runtime.instance.AllocatedSlotTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method private scheduleTask(task ScheduledUnit, queueIfNoResource boolean) : Object in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type sA2 : AllocatedSlot to sA2 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testLocalizedAssignment2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s7 : AllocatedSlot to s7 : SimpleSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s6 : AllocatedSlot to s6 : SimpleSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s5 : AllocatedSlot to s5 : SimpleSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type subslot : SubSlot to subslot : SimpleSlot in method public getSlotForTask(vertex ExecutionVertex, constraint CoLocationConstraint) : SimpleSlot in class org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroupAssignment |
From |
To |
|
Change Variable Type s12 : AllocatedSlot to s12 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public nonColocationFollowsCoLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testScheduleWithDyingInstances() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testFailCallOvertakesDeploymentAnswer() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexDeploymentTest |
From |
To |
|
Change Variable Type sa : AllocatedSlot to sa : SimpleSlot in method public testSlotReleasedInBetweenAndNoNewLocal() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type next : AllocatedSlot to next : SimpleSlot in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s10 : AllocatedSlot to s10 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s7_2 : AllocatedSlot to s7_2 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : Slot in method public markDead() : void in class org.apache.flink.runtime.instance.Instance |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method private writeJsonForArchivedJob(wrt PrintWriter, graph ExecutionGraph) : void in class org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public addIfInstanceIsAllocatedByJob(instanceProfilingData InternalInstanceProfilingData) : boolean in class org.apache.flink.runtime.profiling.impl.JobProfilingData |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_2 : AllocatedSlot to s1_2 : SimpleSlot in method public scheduleImmediatelyWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type sB0 : AllocatedSlot to sB0 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method private sendFailIntermediateResultPartitionsRPCCall() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s7 : AllocatedSlot to s7 : SimpleSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testSlotReleasedInBetweenAndNoNewLocal() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot_3 : AllocatedSlot to slot_3 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testSlotReleasedWhenScheduledImmediately() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexSchedulingTest |
From |
To |
|
Change Variable Type queuedInstance : Instance to instanceLocalityPair : Pair<Instance,Locality> in method protected getFreeSlotForTask(vertex ExecutionVertex, requestedLocations Iterable<Instance>) : SimpleSlot in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type s1 : AllocatedSlot to s1 : SimpleSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type sb : AllocatedSlot to sb : SimpleSlot in method public testSlotReleasedInBetweenAndNoNewLocal() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s1_2 : AllocatedSlot to s1_2 : SimpleSlot in method public scheduleImmediatelyWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public scheduleImmediatelyWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s6_2 : AllocatedSlot to s6_2 : SimpleSlot in method public scheduleImmediatelyWithTemprarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method protected getFreeSlotForTask(vertex ExecutionVertex, requestedLocations Iterable<Instance>) : SimpleSlot in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type s3 : AllocatedSlot to s3 : SimpleSlot in method public testLocalizedAssignment2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_2_3 : AllocatedSlot to slot_2_3 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_1 : AllocatedSlot to s2_1 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s6 : AllocatedSlot to s6 : SimpleSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_4_3 : AllocatedSlot to slot_4_3 : SimpleSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : AllocatedSlot to s4 : SimpleSlot in method public nonColocationFollowsCoLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s33 : AllocatedSlot to s33 : SimpleSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s4_2 : AllocatedSlot to s4_2 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testDeployWithAsynchronousAnswer() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexDeploymentTest |
From |
To |
|
Change Variable Type s3_2 : AllocatedSlot to s3_2 : SimpleSlot in method public scheduleImmediatelyWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_2 : AllocatedSlot to s1_2 : SimpleSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3_1 : AllocatedSlot to s3_1 : SimpleSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public getInstanceSummaryProfilingData(timestamp long) : InstanceSummaryProfilingEvent in class org.apache.flink.runtime.profiling.impl.JobProfilingData |
From |
To |
|
Change Variable Type s2 : AllocatedSlot to s2 : SimpleSlot in method public testSlotReleasedInBetweenAndNoNewLocal() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : AllocatedSlot to slot : SimpleSlot in method public testDeployFailedSynchronous() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexDeploymentTest |
From |
To |