|
Change Variable Type reservedSlots : Collection<AllocationID> to reservedSlots : Collection<SlotOffer> in method private offerSlotsToJobManager(jobId JobID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Variable Type acceptedSlots : Iterable<AllocationID> to acceptedSlots : Iterable<SlotOffer> in method private offerSlotsToJobManager(jobId JobID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Variable Type reservedSlotsIterator : Iterator<AllocationID> to reservedSlotsIterator : Iterator<TaskSlot> in method private offerSlotsToJobManager(jobId JobID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Variable Type acceptedSlot : AllocationID to acceptedSlot : SlotOffer in method private offerSlotsToJobManager(jobId JobID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Variable Type reservedSlot : AllocationID to reservedSlot : SlotOffer in method private offerSlotsToJobManager(jobId JobID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Variable Type rejectedSlot : AllocationID to rejectedSlot : SlotOffer in method private offerSlotsToJobManager(jobId JobID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Variable Type acceptedSlotsFuture : Future<Iterable<AllocationID>> to acceptedSlotsFuture : Future<Iterable<SlotOffer>> in method private offerSlotsToJobManager(jobId JobID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |