|
Change Variable Type deployAction : Future<Object> to deployAction : scala.concurrent.Future<Object> in method public deployToSlot(slot SimpleSlot) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type futureUpdate : Future<Object> to futureUpdate : scala.concurrent.Future<Object> in method private sendUpdatePartitionInfoRpcCall(consumerSlot SimpleSlot, updatePartitionInfo UpdatePartitionInfo) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type stopResult : Future<Object> to stopResult : scala.concurrent.Future<Object> in method public stop() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type allAllocatedSlots : List<SlotAllocationFuture> to allAllocatedSlots : List<Future<SimpleSlot>> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type future : SlotAllocationFuture to future : Future<SimpleSlot> in method public testScheduleQueueing() : void in class org.apache.flink.runtime.jobmanager.scheduler.SchedulerIsolatedTasksTest |
From |
To |
|
Change Variable Type cancelResult : Future<Object> to cancelResult : scala.concurrent.Future<Object> in method private sendCancelRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type future : SlotAllocationFuture to future : Future<SimpleSlot> in method public scheduleForExecution(slotProvider SlotProvider, queued boolean) : boolean in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |