40dce2909e9a5c3d915bd8c27c3e59bc102e9a15
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable taskManagerRunners : TaskManagerRunner[] to taskExecutors : TaskExecutor[] in method protected startTaskManagers(configuration Configuration, haServices HighAvailabilityServices, metricRegistry MetricRegistry, numTaskManagers int, taskManagerRpcServices RpcService[]) : TaskExecutor[] in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Change Return Type | 2 | ||
| Change Return Type int to void in method private run(args String[]) : void in class org.apache.flink.yarn.YarnTaskExecutorRunner | From | To | |
| Change Return Type TaskManagerRunner[] to TaskExecutor[] in method protected startTaskManagers(configuration Configuration, haServices HighAvailabilityServices, metricRegistry MetricRegistry, numTaskManagers int, taskManagerRpcServices RpcService[]) : TaskExecutor[] in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private metricRegistry : MetricRegistry from class org.apache.flink.yarn.YarnTaskExecutorRunner to private metricRegistry : MetricRegistry from class org.apache.flink.runtime.taskexecutor.TaskManagerRunner | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute taskManagerRunners : TaskManagerRunner[] to taskManagers : TaskExecutor[] in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type tm : TaskManagerRunner to tm : TaskExecutor in method private shutdownInternally() : void in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Change Variable Type taskManagerRunners : TaskManagerRunner[] to taskExecutors : TaskExecutor[] in method protected startTaskManagers(configuration Configuration, haServices HighAvailabilityServices, metricRegistry MetricRegistry, numTaskManagers int, taskManagerRpcServices RpcService[]) : TaskExecutor[] in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Extract Method | 1 | ||
| Extract Method public startTaskManager(configuration Configuration, resourceID ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, localCommunicationOnly boolean, fatalErrorHandler FatalErrorHandler) : TaskExecutor extracted from public TaskManagerRunner(configuration Configuration, resourceID ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, localCommunicationOnly boolean) in class org.apache.flink.runtime.taskexecutor.TaskManagerRunner | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type taskManagerRunners : TaskManagerRunner[] to taskManagers : TaskExecutor[] in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Change Attribute Type executor : Executor to executor : ExecutorService in class org.apache.flink.runtime.taskexecutor.TaskManagerRunner | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter resourceID : ResourceID to resourceId : ResourceID in method public TaskManagerRunner(configuration Configuration, resourceId ResourceID) in class org.apache.flink.runtime.taskexecutor.TaskManagerRunner | From | To |