7cb42f40eff443b127fabcef5b92b663a1b8af89
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type shuffleEnvironment : ShuffleEnvironment to shuffleEnvironment : ShuffleEnvironment<?,?> in method package TaskManagerServices(taskManagerLocation TaskManagerLocation, memoryManager MemoryManager, ioManager IOManager, shuffleEnvironment ShuffleEnvironment<?,?>, kvStateService KvStateService, broadcastVariableManager BroadcastVariableManager, taskSlotTable TaskSlotTable, jobManagerTable JobManagerTable, jobLeaderService JobLeaderService, taskManagerStateStore TaskExecutorLocalStateStoresManager, taskEventDispatcher TaskEventDispatcher) in class org.apache.flink.runtime.taskexecutor.TaskManagerServices | From | To | |
| Change Return Type | 1 | ||
| Change Return Type ShuffleEnvironment to ShuffleEnvironment<?,?> in method public getShuffleEnvironment() : ShuffleEnvironment<?,?> in class org.apache.flink.runtime.taskexecutor.TaskManagerServices | From | To | |
| Change Variable Type | 5 | ||
| Change Variable Type shuffleEnvironment : ShuffleEnvironment to shuffleEnvironment : ShuffleEnvironment<?,?> in method public testConcurrentAsyncCheckpointCannotFailFinishedStreamTask() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTerminationTest | From | To | |
| Change Variable Type shuffleEnvironment : ShuffleEnvironment to shuffleEnvironment : ShuffleEnvironment<?,?> in method public main(args String[]) : void in class org.apache.flink.runtime.util.JvmExitOnFatalErrorTest.ProcessEntryPoint | From | To | |
| Change Variable Type shuffleEnvironment : ShuffleEnvironment to shuffleEnvironment : ShuffleEnvironment<?,?> in method private createTask(invokableClass Class<? extends AbstractInvokable>) : Task in class org.apache.flink.streaming.runtime.tasks.SynchronousCheckpointITCase | From | To | |
| Change Variable Type shuffleEnvironment : ShuffleEnvironment to shuffleEnvironment : ShuffleEnvironment<?,?> in method private createTask(streamConfig StreamConfig, taskConfig Configuration, state StreamStateHandle, mode int) : Task in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest | From | To | |
| Change Variable Type shuffleEnvironment : ShuffleEnvironment to shuffleEnvironment : ShuffleEnvironment<?,?> in method public createTask(invokable Class<? extends AbstractInvokable>, taskConfig StreamConfig, taskManagerConfig Configuration, taskStateManager TestTaskStateManager, taskManagerActions TaskManagerActions) : Task in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type shuffleEnvironment : ShuffleEnvironment to shuffleEnvironment : ShuffleEnvironment<?,?> in class org.apache.flink.runtime.taskmanager.TaskAsyncCallTest | From | To | |
| Change Attribute Type shuffleEnvironment : ShuffleEnvironment to shuffleEnvironment : ShuffleEnvironment<?,?> in class org.apache.flink.runtime.taskexecutor.TaskManagerServices | From | To | |
| Change Attribute Type shuffleEnvironment : ShuffleEnvironment to shuffleEnvironment : ShuffleEnvironment<?,?> in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To |