9541afd2c53fc55cee7f0f45b4e16377803f1388
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 17
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public setCancelCondition(predicate Consumer<ExecutionAttemptID>) : void renamed to public setCancelConsumer(predicate Consumer<ExecutionAttemptID>) : void in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway | From | To | |
| Rename Method public setCondition(predicate Consumer<ExecutionAttemptID>) : void renamed to public setSubmitConsumer(predicate Consumer<ExecutionAttemptID>) : void in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway | From | To | |
| Rename Method private freeSlot(allocationId AllocationID, cause Throwable) : void renamed to private freeSlotInternal(allocationId AllocationID, cause Throwable) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Change Return Type | 3 | ||
| Change Return Type void to Set<AllocatedSlot> in method package removeAllForTaskManager(taskManager ResourceID) : Set<AllocatedSlot> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool.AvailableSlots | From | To | |
| Change Return Type void to CompletableFuture<Acknowledge> in method public disconnectTaskManager(resourceID ResourceID, cause Exception) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Change Return Type void to CompletableFuture<Acknowledge> in method public disconnectTaskManager(resourceID ResourceID, cause Exception) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMasterGateway | From | To | |
| Rename Attribute | 4 | ||
| Rename Attribute resourceManagerRequestsTimeout : Time to timeout : Time in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Rename Attribute optSubmitCondition : Optional<Consumer<ExecutionAttemptID>> to optSubmitConsumer : Optional<Consumer<ExecutionAttemptID>> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway | From | To | |
| Rename Attribute DEFAULT_RM_REQUEST_TIMEOUT : Time to DEFAULT_TIMEOUT : Time in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Rename Attribute optCancelCondition : Optional<Consumer<ExecutionAttemptID>> to optCancelConsumer : Optional<Consumer<ExecutionAttemptID>> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type taskManagerGateway : TaskManagerGateway to taskManagerGateway : SimpleAckingTaskManagerGateway in class org.apache.flink.runtime.jobmaster.slotpool.SlotPoolTest | From | To | |
| Extract Method | 1 | ||
| Extract Method private clear() : void extracted from public suspend() : void in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter resourceID : ResourceID to resourceId : ResourceID in method public releaseTaskManager(resourceId ResourceID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Rename Parameter resourceID : ResourceID to resourceId : ResourceID in method public releaseTaskManager(resourceId ResourceID) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPoolGateway | From | To |