|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method package internalAllocateSlot(requestId SlotRequestID, task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type consumerSlot : SimpleSlot to consumerSlot : LogicalSlot in method public testMixedLocalRemoteUnknownDeployment() : void in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptorTest |
From |
To |
|
Change Variable Type s5 : SimpleSlot to s5 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type slot_2_2 : SimpleSlot to slot_2_2 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3_2 : SimpleSlot to s3_2 : LogicalSlot in method public allocateSlotWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_0 : SimpleSlot to s2_0 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sA2 : SimpleSlot to sA2 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slots : List<SimpleSlot> to slots : List<LogicalSlot> in method public testScheduleWithDyingInstances() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s5 : SimpleSlot to s5 : LogicalSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testLocalizedAssignment2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type currentAssignedResource : SimpleSlot to currentAssignedResource : LogicalSlot in method public getAssignedResourceLocation() : TaskManagerLocation in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s9 : SimpleSlot to s9 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s3_2 : SimpleSlot to s3_2 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_4_3 : SimpleSlot to slot_4_3 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3_3 : SimpleSlot to s3_3 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testScheduleOutOfOrder() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testSlotAllocationNoResourceManager() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Change Variable Type s6 : SimpleSlot to s6 : LogicalSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public testLocalizedAssignment2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4_2 : SimpleSlot to s4_2 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method private sendUpdatePartitionInfoRpcCall(partitionInfos Iterable<PartitionInfo>) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s3_1 : SimpleSlot to s3_1 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_1_3 : SimpleSlot to slot_1_3 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testTimeoutForSlotAllocation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot_3 : SimpleSlot to slot_3 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public nonColocationFollowsCoLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s3_3 : SimpleSlot to s3_3 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sourceFutures : CompletableFuture<SimpleSlot>[] to sourceFutures : CompletableFuture<LogicalSlot>[] in method public testDeployPipelinedConnectedComponentsTogether() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public testLocalizedAssignment1() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type producerSlot : SimpleSlot to producerSlot : LogicalSlot in method public fromEdges(edges ExecutionEdge[], consumerResourceId ResourceID, allowLazyDeployment boolean) : InputChannelDeploymentDescriptor[] in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public cancel() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public triggerCheckpoint(checkpointId long, timestamp long, checkpointOptions CheckpointOptions) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method private mockExecutionVertex(state ExecutionState, resourceId ResourceID) : ExecutionVertex in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptorTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public testOfferSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type s6 : SimpleSlot to s6 : LogicalSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testOfferSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testAllocateSimpleSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type sB0 : SimpleSlot to sB0 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sNew : SimpleSlot to sNew : LogicalSlot in method public scheduleWithIntermediateRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method package cancelingComplete(userAccumulators Map<String,Accumulator<?,?>>, metrics IOMetrics) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testSlotReleasedInBetweenAndNoNewLocal() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slotFutures : CompletableFuture<SimpleSlot>[] to slotFutures : CompletableFuture<LogicalSlot>[] in method public testTimeoutForSlotAllocation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type targetFuture : CompletableFuture<SimpleSlot> to targetFuture : CompletableFuture<LogicalSlot> in method public testScheduleSourceBeforeTarget() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public testScheduleOutOfOrder() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public testTddProducedPartitionsLazyScheduling() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexDeploymentTest |
From |
To |
|
Change Variable Type s2_3 : SimpleSlot to s2_3 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type forTask : CompletableFuture<SimpleSlot>[] to forTask : CompletableFuture<LogicalSlot>[] in method public allocateSlot(task ScheduledUnit, allowQueued boolean, preferredLocations Collection<TaskManagerLocation>) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Change Variable Type s10 : SimpleSlot to s10 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slotFuture : CompletableFuture<SimpleSlot> to slotFuture : CompletableFuture<LogicalSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean, preferredLocations Collection<TaskManagerLocation>) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.instance.SlotPool.ProviderAndOwner |
From |
To |
|
Change Variable Type sSolo : SimpleSlot to sSolo : LogicalSlot in method public scheduleWithIntermediateRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4_2 : SimpleSlot to s4_2 : LogicalSlot in method public allocateSlotWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_2_1 : SimpleSlot to slot_2_1 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type targetFutures : CompletableFuture<SimpleSlot>[] to targetFutures : CompletableFuture<LogicalSlot>[] in method public testOneSlotFailureAbortsDeploy() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type s3_2 : SimpleSlot to s3_2 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type future2 : CompletableFuture<SimpleSlot> to future2 : CompletableFuture<LogicalSlot> in method public testAllocationFulfilledByReturnedSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type sB1 : SimpleSlot to sB1 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sa : SimpleSlot to sa : LogicalSlot in method public testSlotReleasedInBetweenAndNoNewLocal() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4_1 : SimpleSlot to s4_1 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot1 : SimpleSlot to slot1 : LogicalSlot in method public testReleaseResource() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public scheduleWithIntermediateRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s7 : SimpleSlot to s7 : LogicalSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type slotFutureArray : CompletableFuture<SimpleSlot>[] to slotFutureArray : CompletableFuture<LogicalSlot>[] in method public testEagerSchedulingWaitsOnAllInputPreferredLocations() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type s4_1 : SimpleSlot to s4_1 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type iter : Iterator<SimpleSlot> to iter : Iterator<LogicalSlot> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s4_2 : SimpleSlot to s4_2 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_4_2 : SimpleSlot to slot_4_2 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public testSlotReleasedInBetween() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method private scheduleTask(task ScheduledUnit, queueIfNoResource boolean, preferredLocations Iterable<TaskManagerLocation>) : Object in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public testSlotReleasedInBetween() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testProviderAndOwner() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public scheduleWithIntermediateRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean, preferredLocations Collection<TaskManagerLocation>) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testSlotReleasedInBetween() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testSlotReleasedInBetween() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4_3 : SimpleSlot to s4_3 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sB2 : SimpleSlot to sB2 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public nonColocationFollowsCoLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot_1_2 : SimpleSlot to slot_1_2 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s6 : SimpleSlot to s6 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type futures : CompletableFuture<SimpleSlot>[] to futures : CompletableFuture<LogicalSlot>[] in method public addSlot(vertex JobVertexID, subtaskIndex int, future CompletableFuture<LogicalSlot>) : void in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Change Variable Type s6 : SimpleSlot to s6 : LogicalSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s34 : SimpleSlot to s34 : LogicalSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testCancelSlotAllocationWithoutResourceManager() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testLocalizedAssignment2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s33 : SimpleSlot to s33 : LogicalSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s6 : SimpleSlot to s6 : LogicalSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s32 : SimpleSlot to s32 : LogicalSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public testScheduleOutOfOrder() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s31 : SimpleSlot to s31 : LogicalSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_3 : SimpleSlot to s1_3 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public testAllocateSimpleSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type single : SimpleSlot to single : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s7 : SimpleSlot to s7 : LogicalSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type allAllocatedSlots : List<CompletableFuture<SimpleSlot>> to allAllocatedSlots : List<CompletableFuture<LogicalSlot>> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s24 : SimpleSlot to s24 : LogicalSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot2 : SimpleSlot to slot2 : LogicalSlot in method public testAllocationFulfilledByReturnedSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type consumerSlot : SimpleSlot to consumerSlot : LogicalSlot in method package scheduleOrUpdateConsumers(allConsumers List<List<ExecutionEdge>>) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type sourceFutures : CompletableFuture<SimpleSlot>[] to sourceFutures : CompletableFuture<LogicalSlot>[] in method public testOneSlotFailureAbortsDeploy() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type s23 : SimpleSlot to s23 : LogicalSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testLocalizedAssignment1() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_2 : SimpleSlot to s2_2 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method private mockSlot(resourceId ResourceID) : LogicalSlot in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptorTest |
From |
To |
|
Change Variable Type s22 : SimpleSlot to s22 : LogicalSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type sx : SimpleSlot to sx : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slotFuture : CompletableFuture<SimpleSlot> to slotFuture : CompletableFuture<LogicalSlot> in method public testSlotReleaseOnFailedResourceAssignment() : void in class org.apache.flink.runtime.executiongraph.ExecutionTest |
From |
To |
|
Change Variable Type s21 : SimpleSlot to s21 : LogicalSlot in method public scheduleMixedCoLocationSlotSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type targetFutures : CompletableFuture<SimpleSlot>[] to targetFutures : CompletableFuture<LogicalSlot>[] in method public testDeployPipelinedConnectedComponentsTogether() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method private sendFailIntermediateResultPartitionsRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3_1 : SimpleSlot to s3_1 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type future1 : CompletableFuture<SimpleSlot> to future1 : CompletableFuture<LogicalSlot> in method public testAllocationFulfilledByReturnedSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type s8 : SimpleSlot to s8 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot_2_4 : SimpleSlot to slot_2_4 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slotFutures : Map<JobVertexID,CompletableFuture<SimpleSlot>[]> to slotFutures : Map<JobVertexID,CompletableFuture<LogicalSlot>[]> in method public testEagerSchedulingWaitsOnAllInputPreferredLocations() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type s1_3 : SimpleSlot to s1_3 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public testLocalizedAssignment1() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s6 : SimpleSlot to s6 : LogicalSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s1_2 : SimpleSlot to s1_2 : LogicalSlot in method public allocateSlotWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public allocateSlotWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_2 : SimpleSlot to s1_2 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sC0 : SimpleSlot to sC0 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s7 : SimpleSlot to s7 : LogicalSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type typed : CompletableFuture<SimpleSlot> to typed : CompletableFuture<LogicalSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean, preferredLocations Collection<TaskManagerLocation>) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public nonColocationFollowsCoLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testCancelSlotAllocationWithResourceManager() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public allocateSlotWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public toString() : String in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type slot_4_1 : SimpleSlot to slot_4_1 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s7_2 : SimpleSlot to s7_2 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s12 : SimpleSlot to s12 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s5_2 : SimpleSlot to s5_2 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3_0 : SimpleSlot to s3_0 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type newArray : CompletableFuture<SimpleSlot>[] to newArray : CompletableFuture<LogicalSlot>[] in method public addSlot(vertex JobVertexID, subtaskIndex int, future CompletableFuture<LogicalSlot>) : void in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public allocateSlotWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sC1 : SimpleSlot to sC1 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_1_1 : SimpleSlot to slot_1_1 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_2 : SimpleSlot to s1_2 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_2 : SimpleSlot to s1_2 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type consumerSlot : SimpleSlot to consumerSlot : LogicalSlot in method public testUnknownChannelWithoutLazyDeploymentThrows() : void in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptorTest |
From |
To |
|
Change Variable Type s3_2 : SimpleSlot to s3_2 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type future1 : CompletableFuture<SimpleSlot> to future1 : CompletableFuture<LogicalSlot> in method public testReleaseResource() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testSlotReleasedInBetweenAndNoNewLocal() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testCancelSlotAllocationWhileSlotFulfilled() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Change Variable Type slot1 : SimpleSlot to slot1 : LogicalSlot in method public testAllocateWithFreeSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public allocateSlotWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s2_1 : SimpleSlot to s2_1 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s4 : SimpleSlot to s4 : LogicalSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s2_3 : SimpleSlot to s2_3 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_1 : SimpleSlot to s1_1 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type sb : SimpleSlot to sb : LogicalSlot in method public testSlotReleasedInBetweenAndNoNewLocal() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s5 : SimpleSlot to s5 : LogicalSlot in method public testGetsNonLocalFromSharingGroupFirst() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method private processFail(t Throwable, isCallback boolean, userAccumulators Map<String,Accumulator<?,?>>, metrics IOMetrics) : boolean in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s5 : SimpleSlot to s5 : LogicalSlot in method public testSchedulingLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type toRelease : Set<SimpleSlot> to toRelease : Set<LogicalSlot> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public run() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest.testConcurrentAllocateAndRelease.deploy1 |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public run() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest.testConcurrentAllocateAndRelease.deploy2 |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public run() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest.testConcurrentAllocateAndRelease.deploy3 |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public run() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest.testConcurrentAllocateAndRelease.deploy4 |
From |
To |
|
Change Variable Type s1_1 : SimpleSlot to s1_1 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s3 : SimpleSlot to s3 : LogicalSlot in method public testLocalizedAssignment2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type future2 : CompletableFuture<SimpleSlot> to future2 : CompletableFuture<LogicalSlot> in method public testAllocateWithFreeSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method package markFinished(userAccumulators Map<String,Accumulator<?,?>>, metrics IOMetrics) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s5 : SimpleSlot to s5 : LogicalSlot in method public testScheduleImmediately() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type slot2 : SimpleSlot to slot2 : LogicalSlot in method public testAllocateWithFreeSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type s6_2 : SimpleSlot to s6_2 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method private sendCancelRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type slot_2_3 : SimpleSlot to slot_2_3 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slotFuture : CompletableFuture<SimpleSlot> to slotFuture : CompletableFuture<LogicalSlot> in method public testSlotRequestCancellationUponFailingRequest() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type slotsAfter : List<SimpleSlot> to slotsAfter : List<LogicalSlot> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s4_0 : SimpleSlot to s4_0 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public nonColocationFollowsCoLocation() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s2_2 : SimpleSlot to s2_2 : LogicalSlot in method public allocateSlotWithIntermediateTotallyEmptySharingGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public stop() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type next : SimpleSlot to next : LogicalSlot in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s2_2 : SimpleSlot to s2_2 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_2 : SimpleSlot to s2_2 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2_2 : SimpleSlot to s2_2 : LogicalSlot in method public allocateSlotWithSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testLocalizedAssignment1() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_4_4 : SimpleSlot to slot_4_4 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s5 : SimpleSlot to s5 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public requestStackTraceSample(sampleId int, numSamples int, delayBetweenSamples Time, maxStrackTraceDepth int, timeout Time) : CompletableFuture<StackTraceSampleResponse> in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s2_1 : SimpleSlot to s2_1 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup2() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public testScheduleWithDyingInstances() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type s4_2 : SimpleSlot to s4_2 : LogicalSlot in method public testDopIncreases() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public notifyCheckpointComplete(checkpointId long, timestamp long) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s1_1 : SimpleSlot to s1_1 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s5 : SimpleSlot to s5 : LogicalSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1_0 : SimpleSlot to s1_0 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot_1_4 : SimpleSlot to slot_1_4 : LogicalSlot in method public testSequentialAllocateAndRelease() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type slot : Slot to slot : LogicalSlot in method public requestNextInputSplit(vertexID JobVertexID, executionAttempt ExecutionAttemptID) : CompletableFuture<SerializedInputSplit> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Variable Type future1 : CompletableFuture<SimpleSlot> to future1 : CompletableFuture<LogicalSlot> in method public testAllocateWithFreeSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type slot : SimpleSlot to slot : LogicalSlot in method public deploy() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public scheduleWithReleaseNoResource() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type slot1 : SimpleSlot to slot1 : LogicalSlot in method public testAllocationFulfilledByReturnedSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type s4_3 : SimpleSlot to s4_3 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type future2 : CompletableFuture<SimpleSlot> to future2 : CompletableFuture<LogicalSlot> in method public testReleaseResource() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type s2_1 : SimpleSlot to s2_1 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s1 : SimpleSlot to s1 : LogicalSlot in method public testScheduleOutOfOrder() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s8 : SimpleSlot to s8 : LogicalSlot in method public scheduleSingleVertexType() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s11 : SimpleSlot to s11 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type s5_2 : SimpleSlot to s5_2 : LogicalSlot in method public allocateSlotWithTemporarilyEmptyVertexGroup() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s7 : SimpleSlot to s7 : LogicalSlot in method public scheduleAllSharedAndCoLocated() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleWithCoLocationHintTest |
From |
To |
|
Change Variable Type future : CompletableFuture<SimpleSlot> to slotFuture2 : CompletableFuture<LogicalSlot> in method public testExecutionGraphRestartTimeMetric() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphMetricsTest |
From |
To |
|
Change Variable Type sA1 : SimpleSlot to sA1 : LogicalSlot in method public scheduleMixedSharingAndNonSharing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type s2 : SimpleSlot to s2 : LogicalSlot in method public testLocalizedAssignment3() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerSlotSharingTest |
From |
To |
|
Change Variable Type sourceFuture : CompletableFuture<SimpleSlot> to sourceFuture : CompletableFuture<LogicalSlot> in method public testScheduleSourceBeforeTarget() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |