4046819b380b8dfa57d52c6d314f389546a159a3
Files Diff
- Added: 2
- Removed: 2
- Renamed: 0
- Modified: 102
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 1 | ||
Change Parameter Type taskManager : TaskManager to taskManager : ActorRef in method public Task(jobId JobID, vertexId JobVertexID, taskIndex int, parallelism int, executionId ExecutionAttemptID, taskName String, taskManager ActorRef) in class org.apache.flink.runtime.taskmanager.Task | From | To | |
Rename Variable | 1 | ||
Rename Variable akkaURL : String to jobManagerURL : String in method public createTaskManager(jm ActorRef) : ActorRef in class org.apache.flink.runtime.taskmanager.TaskManagerTest | From | To | |
Rename Class | 1 | ||
Rename Class org.apache.flink.runtime.instance.AllocatedSlotTest renamed to org.apache.flink.runtime.instance.SimpleSlotTest | From | To | |
Change Attribute Type | 3 | ||
Change Attribute Type DEFAULT_AKKA_ASK_TIMEOUT : int to DEFAULT_AKKA_ASK_TIMEOUT : String in class org.apache.flink.configuration.ConfigConstants | From | To | |
Change Attribute Type DEFAULT_AKKA_ASK_TIMEOUT : int to DEFAULT_AKKA_ASK_TIMEOUT : long in class org.apache.flink.test.util.TestBaseUtils | From | To | |
Change Attribute Type taskManager : TaskManager to taskManager : ActorRef in class org.apache.flink.runtime.taskmanager.Task | From | To |