e74521c1fe5f5842185be5c454d27adc3bd254d5
Files Diff
- Added: 6
- Removed: 1
- Renamed: 0
- Modified: 37
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type timeout : FiniteDuration to timeout : Timeout in method public TaskInputSplitProvider(jobManager ActorRef, jobId JobID, vertexId JobVertexID, executionID ExecutionAttemptID, userCodeClassLoader ClassLoader, timeout Timeout) in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider | From | To | |
| Change Parameter Type updateTaskMsg : UpdateTask to updateTaskMsg : UpdatePartitionInfo in method private sendUpdateTaskRpcCall(consumerSlot SimpleSlot, updateTaskMsg UpdatePartitionInfo) : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Rename Variable | 1 | ||
| Rename Variable tm : ActorRef to tmClosure : ActorRef in method public testSetupTaskManager() : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest | From | To | |
| Extract Variable | 1 | ||
| Extract Variable self : ActorRef in method public onReceive(message Object) : void from class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimpleJobManager | From | To | |
| Change Variable Type | 7 | ||
| Change Variable Type submitTask : TaskManagerMessages.SubmitTask to submitTask : SubmitTask in method public onReceive(msg Object) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils.SimpleFailingTaskManager | From | To | |
| Change Variable Type submitTask : TaskManagerMessages.SubmitTask to submitTask : SubmitTask in method public onReceive(msg Object) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils.SimpleAcknowledgingTaskManager | From | To | |
| Change Variable Type cancelTask : TaskManagerMessages.CancelTask to cancelTask : CancelTask in method public onReceive(msg Object) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils.SimpleFailingTaskManager | From | To | |
| Change Variable Type updateTaskMessage : UpdateTask to updateTaskMessage : UpdatePartitionInfo in method package sendPartitionInfos() : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Change Variable Type cancelTask : TaskManagerMessages.CancelTask to cancelTask : CancelTask in method public onReceive(msg Object) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils.SimpleAcknowledgingTaskManager | From | To | |
| Change Variable Type nextInputSplit : TaskManagerMessages.NextInputSplit to nextInputSplit : JobManagerMessages.NextInputSplit in method public getNextInputSplit() : InputSplit in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider | From | To | |
| Change Variable Type updateTaskMessage : UpdateTask to updateTaskMessage : UpdatePartitionInfo in method package scheduleOrUpdateConsumers(allConsumers List<List<ExecutionEdge>>) : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type timeout : FiniteDuration to timeout : Timeout in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter errorMsg : String to message : String in method public IllegalConfigurationException(message String) in class org.apache.flink.configuration.IllegalConfigurationException | From | To | |
| Rename Parameter jm : ActorRef to jobManager : ActorRef in method public createTaskManager(jobManager ActorRef) : ActorRef in class org.apache.flink.runtime.taskmanager.TaskManagerTest | From | To | |
| Rename Parameter errorMsg : String to message : String in method public IllegalConfigurationException(message String, cause Throwable) in class org.apache.flink.configuration.IllegalConfigurationException | From | To |