|
Change Parameter Type allocationID : AllocationID to requestId : SlotRequestID in method private stashRequestWaitingForResourceManager(requestId SlotRequestID, resources ResourceProfile, future CompletableFuture<SimpleSlot>) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocationID : AllocationID to slotRequestId : SlotRequestID in method package PendingRequest(slotRequestId SlotRequestID, future CompletableFuture<SimpleSlot>, resourceProfile ResourceProfile) in class org.apache.flink.runtime.instance.SlotPool.PendingRequest |
From |
To |
|
Change Parameter Type allocationId : AllocationID to requestId : SlotRequestID in method private removePendingRequest(requestId SlotRequestID) : PendingRequest in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocationID : AllocationID to requestId : SlotRequestID in method public allocateSlot(requestId SlotRequestID, task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>, timeout Time) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Change Parameter Type allocationId : AllocationID to requestId : SlotRequestID in method public cancelSlotAllocation(requestId SlotRequestID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Change Parameter Type allocationId : AllocationID to requestId : SlotRequestID in method public cancelSlotAllocation(requestId SlotRequestID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocationID : AllocationID to slotRequestId : SlotRequestID in method private checkTimeoutRequestWaitingForResourceManager(slotRequestId SlotRequestID) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocationID : AllocationID to requestId : SlotRequestID in method package internalAllocateSlot(requestId SlotRequestID, task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocationID : AllocationID to slotRequestID : SlotRequestID in method private checkTimeoutSlotAllocation(slotRequestID SlotRequestID) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocationID : AllocationID to requestId : SlotRequestID in method public allocateSlot(requestId SlotRequestID, task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>, timeout Time) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocationID : AllocationID to slotRequestID : SlotRequestID in method private slotRequestToResourceManagerFailed(slotRequestID SlotRequestID, failure Throwable) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type allocationID : AllocationID to requestId : SlotRequestID in method private slotRequestToResourceManagerSuccess(requestId SlotRequestID) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Variable allocationID : AllocationID to requestId : SlotRequestID in method public allocateSlot(task ScheduledUnit, allowQueued boolean, preferredLocations Collection<TaskManagerLocation>) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool.ProviderAndOwner |
From |
To |
|
Rename Variable allocationID : AllocationID to requestId : SlotPoolGateway.SlotRequestID in method public testAllocateSimpleSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Rename Variable pending : PendingRequest to pendingRequest : PendingRequest in method public connectToResourceManager(resourceManagerGateway ResourceManagerGateway) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Variable allocationID : AllocationID to requestId : SlotPoolGateway.SlotRequestID in method public testCancelSlotAllocationWithoutResourceManager() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Rename Variable allocationID : AllocationID to requestId : SlotPoolGateway.SlotRequestID in method public testCancelSlotAllocationWithResourceManager() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Change Return Type AllocationID to SlotRequestID in method public getSlotRequestId() : SlotRequestID in class org.apache.flink.runtime.instance.SlotPool.PendingRequest |
From |
To |
|
Change Return Type HashMap<AllocationID,PendingRequest> to DualKeyMap<SlotRequestID,AllocationID,PendingRequest> in method package getPendingRequests() : DualKeyMap<SlotRequestID,AllocationID,PendingRequest> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Return Type HashMap<AllocationID,PendingRequest> to Map<SlotRequestID,PendingRequest> in method package getWaitingForResourceManager() : Map<SlotRequestID,PendingRequest> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Variable Type allocationID : AllocationID to requestId : SlotPoolGateway.SlotRequestID in method public testAllocateSimpleSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type allocationID : AllocationID to requestId : SlotPoolGateway.SlotRequestID in method public testCancelSlotAllocationWithoutResourceManager() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Change Variable Type allocationID : AllocationID to requestId : SlotPoolGateway.SlotRequestID in method public testCancelSlotAllocationWithResourceManager() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Change Variable Type allocationID : AllocationID to requestId : SlotRequestID in method public allocateSlot(task ScheduledUnit, allowQueued boolean, preferredLocations Collection<TaskManagerLocation>) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool.ProviderAndOwner |
From |
To |
|
Change Variable Type resourceManagerGateway : ResourceManagerGateway to resourceManagerGateway : TestingResourceManagerGateway in method public testCancelSlotAllocationWhileSlotFulfilled() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Rename Parameter allocationID : AllocationID to requestId : SlotRequestID in method private slotRequestToResourceManagerSuccess(requestId SlotRequestID) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocationID : AllocationID to slotRequestID : SlotRequestID in method private slotRequestToResourceManagerFailed(slotRequestID SlotRequestID, failure Throwable) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocationId : AllocationID to requestId : SlotRequestID in method public cancelSlotAllocation(requestId SlotRequestID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Rename Parameter allocationID : AllocationID to slotRequestId : SlotRequestID in method private checkTimeoutRequestWaitingForResourceManager(slotRequestId SlotRequestID) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocationID : AllocationID to slotRequestID : SlotRequestID in method private checkTimeoutSlotAllocation(slotRequestID SlotRequestID) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocationID : AllocationID to slotRequestId : SlotRequestID in method package PendingRequest(slotRequestId SlotRequestID, future CompletableFuture<SimpleSlot>, resourceProfile ResourceProfile) in class org.apache.flink.runtime.instance.SlotPool.PendingRequest |
From |
To |
|
Rename Parameter allocationID : AllocationID to requestId : SlotRequestID in method public allocateSlot(requestId SlotRequestID, task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>, timeout Time) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocationID : AllocationID to requestId : SlotRequestID in method public allocateSlot(requestId SlotRequestID, task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>, timeout Time) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Rename Parameter allocationId : AllocationID to requestId : SlotRequestID in method public cancelSlotAllocation(requestId SlotRequestID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocationID : AllocationID to requestId : SlotRequestID in method private stashRequestWaitingForResourceManager(requestId SlotRequestID, resources ResourceProfile, future CompletableFuture<SimpleSlot>) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocationID : AllocationID to requestId : SlotRequestID in method package internalAllocateSlot(requestId SlotRequestID, task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter allocationId : AllocationID to requestId : SlotRequestID in method private removePendingRequest(requestId SlotRequestID) : PendingRequest in class org.apache.flink.runtime.instance.SlotPool |
From |
To |