27fd2493e98e90bf904f0b6b7424fd4213b04977
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Pull Up Method | 2 | ||
| Pull Up Method public testReapProcessOnFailure() : void from class org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTest to public testReapProcessOnFailure() : void from class org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTestBase | From | To | |
| Pull Up Method private printProcessLog(log String) : void from class org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTest to private printProcessLog(log String) : void from class org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTestBase | From | To | |
| Rename Variable | 1 | ||
| Rename Variable execConfig : SerializedValue<ExecutionConfig> to serializedExecConfig : SerializedValue<ExecutionConfig> in method private createTaskDeploymentDescriptor(invokable Class<? extends AbstractInvokable>, taskConfig Configuration, execConfig ExecutionConfig) : TaskDeploymentDescriptor in class org.apache.flink.runtime.taskmanager.TaskTest | From | To | |
| Move Class | 2 | ||
| Move Class org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTest.PipeForwarder moved to org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTestBase.PipeForwarder | From | To | |
| Move Class org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTest.TaskManagerTestEntryPoint moved to org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTestBase.TaskManagerTestEntryPoint | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTestBase from classes [org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTest] | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute taskCancellationIntervalMillis : long to interruptInterval : long in class org.apache.flink.runtime.taskmanager.Task.TaskCanceler | From | To | |
| Extract Method | 3 | ||
| Extract Method private createTask(invokable Class<? extends AbstractInvokable>, config Configuration, execConfig ExecutionConfig) : Task extracted from private createTask(invokable Class<? extends AbstractInvokable>) : Task in class org.apache.flink.runtime.taskmanager.TaskTest | From | To | |
| Extract Method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager, networkEnvironment NetworkEnvironment, consumableNotifier ResultPartitionConsumableNotifier, partitionStateChecker PartitionStateChecker, executor Executor, config Configuration, execConfig ExecutionConfig) : Task extracted from private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager, networkEnvironment NetworkEnvironment, consumableNotifier ResultPartitionConsumableNotifier, partitionStateChecker PartitionStateChecker, executor Executor) : Task in class org.apache.flink.runtime.taskmanager.TaskTest | From | To | |
| Extract Method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager, config Configuration, execConfig ExecutionConfig) : Task extracted from private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager) : Task in class org.apache.flink.runtime.taskmanager.TaskTest | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter cancelationInterval : long to cancellationInterval : long in method public TaskCanceler(logger Logger, invokable AbstractInvokable, executer Thread, taskName String, cancellationInterval long, cancellationTimeout long, taskManager TaskManagerConnection, producedPartitions ResultPartition[], inputGates SingleInputGate[]) in class org.apache.flink.runtime.taskmanager.Task.TaskCanceler | From | To |