|
Rename Method protected workerRegistered(resourceID ResourceID) : ResourceID renamed to protected workerStarted(resourceID ResourceID) : ResourceID in class org.apache.flink.runtime.clusterframework.standalone.StandaloneResourceManager |
From |
To |
|
Rename Method public getRegisteredTaskManagers() : Collection<WorkerType> renamed to public getStartedTaskManagers() : Collection<WorkerType> in class org.apache.flink.runtime.clusterframework.FlinkResourceManager |
From |
To |
|
Rename Method private handleRegisterResource(jobManager ActorRef, taskManager ActorRef, msg RegistrationMessages.RegisterTaskManager) : void renamed to private handleResourceStarted(jobManager ActorRef, resourceID ResourceID) : void in class org.apache.flink.runtime.clusterframework.FlinkResourceManager |
From |
To |
|
Rename Method public isRegistered(resourceId ResourceID) : boolean renamed to public isStarted(resourceId ResourceID) : boolean in class org.apache.flink.runtime.clusterframework.FlinkResourceManager |
From |
To |
|
Rename Method protected releaseRegisteredWorker(worker RegisteredYarnWorkerNode) : void renamed to protected releaseStartedWorker(worker RegisteredYarnWorkerNode) : void in class org.apache.flink.yarn.YarnFlinkResourceManager |
From |
To |
|
Rename Method public allRegisteredWorkers() : Collection<WorkerType> renamed to public allStartedWorkers() : Collection<WorkerType> in class org.apache.flink.runtime.clusterframework.FlinkResourceManager |
From |
To |
|
Rename Method public getNumberOfRegisteredTaskManagers() : int renamed to public getNumberOfStartedTaskManagers() : int in class org.apache.flink.runtime.clusterframework.FlinkResourceManager |
From |
To |
|
Rename Method protected abstract releaseRegisteredWorker(resourceID WorkerType) : void renamed to protected abstract releaseStartedWorker(resourceID WorkerType) : void in class org.apache.flink.runtime.clusterframework.FlinkResourceManager |
From |
To |
|
Rename Method protected workerRegistered(resourceID ResourceID) : RegisteredYarnWorkerNode renamed to protected workerStarted(resourceID ResourceID) : RegisteredYarnWorkerNode in class org.apache.flink.yarn.YarnFlinkResourceManager |
From |
To |