e3c98f05d3544d0165c2d97d2d00fcd295cef8c8
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 3 | ||
| Change Return Type void to CompletableFuture<SerializableOptional<ResourceID>> in method public failAllocation(allocationID AllocationID, cause Exception) : CompletableFuture<SerializableOptional<ResourceID>> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Change Return Type boolean to AllocatedSlot in method package tryRemove(slotId AllocationID) : AllocatedSlot in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool.AvailableSlots | From | To | |
| Change Return Type void to CompletableFuture<SerializableOptional<ResourceID>> in method public failAllocation(allocationID AllocationID, cause Exception) : CompletableFuture<SerializableOptional<ResourceID>> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPoolGateway | From | To | |
| Extract Variable | 1 | ||
| Extract Variable allocatedSlot : AllocatedSlot in method private tryFailingAllocatedSlot(allocationID AllocationID, cause Exception) : CompletableFuture<SerializableOptional<ResourceID>> from class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Extract Method | 4 | ||
| Extract Method private tryFailingAllocatedSlot(allocationID AllocationID, cause Exception) : CompletableFuture<SerializableOptional<ResourceID>> extracted from public failAllocation(allocationID AllocationID, cause Exception) : void in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Extract Method private allocateSlot(slotPoolGateway SlotPoolGateway, slotRequestId SlotRequestId) : CompletableFuture<LogicalSlot> extracted from public testReleasingIdleSlotFailed() : void in class org.apache.flink.runtime.jobmaster.slotpool.SlotPoolTest | From | To | |
| Extract Method private internalFailAllocation(allocationId AllocationID, cause Exception) : void extracted from public failSlot(taskManagerId ResourceID, allocationId AllocationID, cause Exception) : void in class org.apache.flink.runtime.jobmaster.JobMaster | From | To |