|
Move Method private parseTaskManagerConfiguration(configuration Configuration, taskManagerHostname String, localTaskManagerCommunication boolean) : TaskExecutorConfiguration from class org.apache.flink.runtime.taskexecutor.TaskExecutor to private parseTaskManagerConfiguration(configuration Configuration, taskManagerHostname String, localTaskManagerCommunication boolean) : TaskExecutorConfiguration from class org.apache.flink.runtime.taskmanager.TaskManagerRunner |
From |
To |
|
Move Method private createTaskManagerComponents(resourceID ResourceID, taskManagerAddress InetAddress, taskExecutorConfig TaskExecutorConfiguration, configuration Configuration) : TaskExecutor.TaskManagerComponents from class org.apache.flink.runtime.taskexecutor.TaskExecutor to private createTaskManagerComponents(resourceID ResourceID, taskManagerAddress InetAddress, taskExecutorConfig TaskExecutorConfiguration, configuration Configuration) : TaskManagerComponents from class org.apache.flink.runtime.taskmanager.TaskManagerRunner |
From |
To |
|
Move Method private checkConfigParameter(condition boolean, parameter Object, name String, errorMessage String) : void from class org.apache.flink.runtime.taskexecutor.TaskExecutor to private checkConfigParameter(condition boolean, parameter Object, name String, errorMessage String) : void from class org.apache.flink.runtime.taskmanager.TaskManagerRunner |
From |
To |
|
Move Method private checkTempDirs(tmpDirs String[]) : void from class org.apache.flink.runtime.taskexecutor.TaskExecutor to private checkTempDirs(tmpDirs String[]) : void from class org.apache.flink.runtime.taskmanager.TaskManagerRunner |
From |
To |
|
Change Return Type TaskExecutor.TaskManagerComponents to TaskManagerComponents in method private createTaskManagerComponents(resourceID ResourceID, taskManagerAddress InetAddress, taskExecutorConfig TaskExecutorConfiguration, configuration Configuration) : TaskManagerComponents in class org.apache.flink.runtime.taskmanager.TaskManagerRunner |
From |
To |
|
Change Return Type TaskExecutor to void in method private createAndStartTaskManagerComponents(configuration Configuration, resourceID ResourceID, rpcService RpcService, taskManagerHostname String, haServices HighAvailabilityServices, localTaskManagerCommunication boolean) : void in class org.apache.flink.runtime.taskmanager.TaskManagerRunner |
From |
To |
|
Change Return Type InetSocketAddress to String in method private selectNetworkInterface(configuration Configuration) : String in class org.apache.flink.runtime.taskmanager.TaskManagerRunner |
From |
To |