1aad5b759432f0b59a9dcc366a4b66c2681626f1
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 35
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public testExecutionFailesAfterTaskMarkedFailed() : void renamed to public testExecutionFailsAfterTaskMarkedFailed() : void in class org.apache.flink.runtime.taskmanager.TaskTest | From | To | |
| Rename Variable | 1 | ||
| Rename Variable queueIterator : ResultSubpartitionView to subpartition : ResultSubpartitionView in method protected channelRead0(ctx ChannelHandlerContext, msg NettyMessage) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestServerHandler | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type updateMsg : TaskMessages.UpdateTaskExecutionState to updateMsg : UpdateTaskExecutionState in method public onReceive(message Object) : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimpleLookupFailingUpdateJobManager | From | To | |
| Extract Variable | 2 | ||
| Extract Variable listener : ChannelFutureListener in method public requestSubpartition(partitionId ResultPartitionID, subpartitionIndex int, inputChannel RemoteInputChannel, delayMs int) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClient | From | To | |
| Extract Variable request : PartitionRequest in method public requestSubpartition(partitionId ResultPartitionID, subpartitionIndex int, inputChannel RemoteInputChannel, delayMs int) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClient | From | To | |
| Extract Method | 2 | ||
| Extract Method public createTaskManager(jobManager ActorRef, waitForRegistration boolean, useLocalCommunication boolean, dataPort int) : ActorRef extracted from public createTaskManager(jobManager ActorRef, waitForRegistration boolean) : ActorRef in class org.apache.flink.runtime.taskmanager.TaskManagerTest | From | To | |
| Extract Method private createRemoteInputChannel(inputGate SingleInputGate, partitionRequestClient PartitionRequestClient, initialAndMaxRequestBackoff Tuple2<Integer,Integer>) : RemoteInputChannel extracted from private createRemoteInputChannel(inputGate SingleInputGate) : RemoteInputChannel in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannelTest | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type error : Throwable to error : AtomicReference<Throwable> in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To |