63d4819e197b1df1651157fd8f86c8ca0540d0b1
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 1 | ||
Rename Method public getFailareMessage() : String renamed to public getConnectionFuture() : CompletableFuture<String> in class org.apache.flink.runtime.registration.RegisteredRpcConnectionTest.TestRpcConnection | From | To | |
Rename Variable | 1 | ||
Rename Variable freedSlotIndex : int to taskSlot : TaskSlot in method private freeSlotInternal(allocationId AllocationID, cause Throwable) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
Change Return Type | 3 | ||
Change Return Type int to TaskSlot in method public freeSlot(allocationId AllocationID, cause Throwable) : TaskSlot in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable | From | To | |
Change Return Type String to CompletableFuture<String> in method public getConnectionFuture() : CompletableFuture<String> in class org.apache.flink.runtime.registration.RegisteredRpcConnectionTest.TestRpcConnection | From | To | |
Change Return Type int to TaskSlot in method public freeSlot(allocationId AllocationID) : TaskSlot in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable | From | To | |
Extract Variable | 1 | ||
Extract Variable registrationException : RuntimeException in method public testRpcConnectionFailures() : void from class org.apache.flink.runtime.registration.RegisteredRpcConnectionTest | From | To | |
Change Variable Type | 1 | ||
Change Variable Type freedSlotIndex : int to taskSlot : TaskSlot in method private freeSlotInternal(allocationId AllocationID, cause Throwable) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
Extract Method | 1 | ||
Extract Method private createNewRegistration() : RetryingRegistration<F,G,S> extracted from public start() : void in class org.apache.flink.runtime.registration.RegisteredRpcConnection | From | To |