|
Change Return Type Future<SimpleSlot> to CompletableFuture<SimpleSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool.ProviderAndOwner |
From |
To |
|
Change Return Type Future<SimpleSlot> to CompletableFuture<SimpleSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Change Return Type Future<SimpleSlot> to CompletableFuture<SimpleSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |
|
Change Return Type Future<SimpleSlot> to CompletableFuture<SimpleSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotProvider |
From |
To |
|
Change Return Type Future<SimpleSlot> to CompletableFuture<SimpleSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.executiongraph.utils.SimpleSlotProvider |
From |
To |
|
Change Variable Type forTask : Future<SimpleSlot>[] to forTask : CompletableFuture<SimpleSlot>[] in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Change Variable Type future : Future<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type sourceFuture : FlinkCompletableFuture<SimpleSlot> to sourceFuture : CompletableFuture<SimpleSlot> in method public testScheduleSourceBeforeTarget() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type future : FlinkCompletableFuture<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public testSlotReleasedWhenScheduledQueued() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexSchedulingTest |
From |
To |
|
Change Variable Type future : FlinkCompletableFuture<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public testExecutionGraphRestartTimeMetric() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphMetricsTest |
From |
To |
|
Change Variable Type futures : Future<SimpleSlot>[] to futures : CompletableFuture<SimpleSlot>[] in method public addSlot(vertex JobVertexID, subtaskIndex int, future CompletableFuture<SimpleSlot>) : void in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Change Variable Type future : Future<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public testTimeoutForSlotAllocation() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type future : FlinkCompletableFuture<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public testSlotReleasedWhenScheduledImmediately() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexSchedulingTest |
From |
To |
|
Change Variable Type future : Future<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.executiongraph.ProgrammedSlotProvider |
From |
To |
|
Change Variable Type targetFuture : FlinkCompletableFuture<SimpleSlot> to targetFuture : CompletableFuture<SimpleSlot> in method public testScheduleSourceBeforeTarget() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest |
From |
To |
|
Change Variable Type future : FlinkCompletableFuture<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public testScheduleToDeploying() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexSchedulingTest |
From |
To |
|
Change Variable Type allAllocatedSlots : List<Future<SimpleSlot>> to allAllocatedSlots : List<CompletableFuture<SimpleSlot>> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type typed : Future<SimpleSlot> to typed : CompletableFuture<SimpleSlot> in method public allocateSlot(task ScheduledUnit, allowQueued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.jobmanager.scheduler.Scheduler |
From |
To |