|
Change Parameter Type preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerTestBase.TestingSchedulerSlotProvider |
From |
To |
|
Change Parameter Type preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerTestBase.TestingSlotPoolSlotProvider |
From |
To |
|
Change Parameter Type preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Change Parameter Type preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Parameter Type preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, timeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool.ProviderAndOwner |
From |
To |
|
Change Parameter Type preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, timeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotProvider |
From |
To |
|
Change Parameter Type preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.executiongraph.utils.SimpleSlotProvider |
From |
To |
|
Change Parameter Type preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, timeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotProvider |
From |
To |
|
Merge Parameter [resourceProfile : ResourceProfile, locationPreferences : Collection<TaskManagerLocation>] to slotProfile : SlotProfile in method private requestAllocatedSlot(slotRequestId SlotRequestId, slotProfile SlotProfile, allowQueuedScheduling boolean, allocationTimeout Time) : CompletableFuture<SlotAndLocality> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool |
From |
To |
|
Merge Parameter [resourceProfile : ResourceProfile, locationPreferences : Collection<TaskManagerLocation>] to slotProfile : SlotProfile in method private allocateMultiTaskSlot(groupId AbstractID, slotSharingManager SlotSharingManager, slotProfile SlotProfile, allowQueuedScheduling boolean, allocationTimeout Time) : SlotSharingManager.MultiTaskSlotLocality in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool |
From |
To |
|
Merge Parameter [resourceProfile : ResourceProfile, locationPreferences : Collection<TaskManagerLocation>] to slotProfile : SlotProfile in method private internalAllocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, slotProfile SlotProfile, allowQueuedScheduling boolean, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool |
From |
To |
|
Merge Parameter [resourceProfile : ResourceProfile, locationPreferences : Collection<TaskManagerLocation>] to slotProfile : SlotProfile in method private pollAndAllocateSlot(slotRequestId SlotRequestId, slotProfile SlotProfile) : SlotAndLocality in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool |
From |
To |
|
Merge Parameter [resourceProfile : ResourceProfile, locationPreferences : Collection<TaskManagerLocation>] to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, scheduledUnit ScheduledUnit, slotProfile SlotProfile, allowQueuedScheduling boolean, timeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool |
From |
To |
|
Rename Parameter preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Rename Parameter preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Rename Parameter preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, timeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool.ProviderAndOwner |
From |
To |
|
Rename Parameter preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, timeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotProvider |
From |
To |
|
Rename Parameter preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.executiongraph.utils.SimpleSlotProvider |
From |
To |
|
Rename Parameter preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, timeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotProvider |
From |
To |
|
Rename Parameter preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerTestBase.TestingSchedulerSlotProvider |
From |
To |
|
Rename Parameter preferredLocations : Collection<TaskManagerLocation> to slotProfile : SlotProfile in method public allocateSlot(slotRequestId SlotRequestId, task ScheduledUnit, allowQueued boolean, slotProfile SlotProfile, allocationTimeout Time) : CompletableFuture<LogicalSlot> in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerTestBase.TestingSlotPoolSlotProvider |
From |
To |