a7274d5661421a66dcb998efd72b547301e1dc0f
Files Diff
- Added: 6
- Removed: 1
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type delayBetweenAttempts : long to delayBetweenAttemptsInterval : Time in method package FixedDelayRestartStrategyConfiguration(restartAttempts int, delayBetweenAttemptsInterval Time) in class org.apache.flink.api.common.restartstrategy.RestartStrategies.FixedDelayRestartStrategyConfiguration | From | To | |
| Rename Variable | 7 | ||
| Rename Variable sender : JobVertex to groupVertex : JobVertex in method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Rename Variable executionGraph : ExecutionGraph to eg : ExecutionGraph in method private createExecutionGraph(restartStrategy RestartStrategy, isSpy boolean) : Tuple2<ExecutionGraph,Instance> in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Rename Variable jobVertex : JobVertex to sender : JobVertex in method private createExecutionGraph(restartStrategy RestartStrategy, isSpy boolean) : Tuple2<ExecutionGraph,Instance> in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Rename Variable jobVertex : JobVertex to groupVertex : JobVertex in method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Rename Variable vertex : JobVertex to groupVertex : JobVertex in method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Move Class | 3 | ||
| Move Class org.apache.flink.test.recovery.SimpleRecoveryITCase.FailingMapper3 moved to org.apache.flink.test.recovery.SimpleRecoveryITCaseBase.FailingMapper3 | From | To | |
| Move Class org.apache.flink.test.recovery.SimpleRecoveryITCase.FailingMapper1 moved to org.apache.flink.test.recovery.SimpleRecoveryITCaseBase.FailingMapper1 | From | To | |
| Move Class org.apache.flink.test.recovery.SimpleRecoveryITCase.FailingMapper2 moved to org.apache.flink.test.recovery.SimpleRecoveryITCaseBase.FailingMapper2 | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute delayBetweenAttempts : long to delayBetweenAttemptsInterval : Time in class org.apache.flink.api.common.restartstrategy.RestartStrategies.FixedDelayRestartStrategyConfiguration | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type delayBetweenAttempts : long to delayBetweenAttemptsInterval : Time in class org.apache.flink.api.common.restartstrategy.RestartStrategies.FixedDelayRestartStrategyConfiguration | From | To | |
| Extract Method | 23 | ||
| Extract Method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex extracted from public testFailExecutionGraphAfterCancel() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private createExecutionGraph(restartStrategy RestartStrategy) : Tuple2<ExecutionGraph,Instance> extracted from public testRestartAutomatically() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newExecutionGraph(restartStrategy RestartStrategy) : ExecutionGraph extracted from public testFailExecutionAfterCancel() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private createExecutionGraph(restartStrategy RestartStrategy) : Tuple2<ExecutionGraph,Instance> extracted from public testNoManualRestart() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newExecutionGraph(restartStrategy RestartStrategy) : ExecutionGraph extracted from public testFailingExecutionAfterRestart() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private createExecutionGraph(restartStrategy RestartStrategy) : Tuple2<ExecutionGraph,Instance> extracted from public testCancelWhileRestarting() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newExecutionGraph(restartStrategy RestartStrategy) : ExecutionGraph extracted from public testConstraintsAfterRestart() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex extracted from public testConstraintsAfterRestart() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method public fixedDelayRestart(restartAttempts int, delayInterval Time) : RestartStrategyConfiguration extracted from public fixedDelayRestart(restartAttempts int, delayBetweenAttempts long) : RestartStrategyConfiguration in class org.apache.flink.api.common.restartstrategy.RestartStrategies | From | To | |
| Extract Method private waitForAsyncRestart(eg ExecutionGraph, timeout FiniteDuration) : void extracted from private restartAfterFailure(eg ExecutionGraph, timeout FiniteDuration, haltAfterRestart boolean) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private waitForAsyncRestart(eg ExecutionGraph, timeout FiniteDuration) : void extracted from public testFailingExecutionAfterRestart() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newExecutionGraph(restartStrategy RestartStrategy) : ExecutionGraph extracted from public testCancelWhileRestarting() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex extracted from public testCancelWhileRestarting() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex extracted from public testRestartAutomatically() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newExecutionGraph(restartStrategy RestartStrategy) : ExecutionGraph extracted from public testNoManualRestart() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private waitForAllResourcesToBeAssignedAfterAsyncRestart(eg ExecutionGraph, deadline Deadline) : void extracted from private restartAfterFailure(eg ExecutionGraph, timeout FiniteDuration, haltAfterRestart boolean) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex extracted from public testNoManualRestart() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex extracted from public testFailExecutionAfterCancel() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newJobVertex(task1 String, numTasks int, invokable Class<Tasks.NoOpInvokable>) : JobVertex extracted from public testFailingExecutionAfterRestart() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private makeAFailureAndWait(eg ExecutionGraph, timeout FiniteDuration) : void extracted from private restartAfterFailure(eg ExecutionGraph, timeout FiniteDuration, haltAfterRestart boolean) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newExecutionGraph(restartStrategy RestartStrategy) : ExecutionGraph extracted from public testFailExecutionGraphAfterCancel() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private newExecutionGraph(restartStrategy RestartStrategy) : ExecutionGraph extracted from public testRestartAutomatically() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Extract Method private waitForAllResourcesToBeAssignedAfterAsyncRestart(eg ExecutionGraph, deadline Deadline) : void extracted from public testFailingExecutionAfterRestart() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphRestartTest | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter delayBetweenAttempts : long to delayBetweenAttemptsInterval : Time in method package FixedDelayRestartStrategyConfiguration(restartAttempts int, delayBetweenAttemptsInterval Time) in class org.apache.flink.api.common.restartstrategy.RestartStrategies.FixedDelayRestartStrategyConfiguration | From | To |