|
Rename Variable resourceManagers : StandaloneResourceManager[] to resourceManagerRunners : ResourceManagerRunner[] in method protected startResourceManagers(configuration Configuration, haServices HighAvailabilityServices, metricRegistry MetricRegistry, numResourceManagers int, resourceManagerRpcServices RpcService[]) : ResourceManagerRunner[] in class org.apache.flink.runtime.minicluster.MiniCluster |
From |
To |
|
Rename Variable worker : WorkerType to workerRegistration : WorkerRegistration<WorkerType> in method public run() : void in class org.apache.flink.runtime.resourcemanager.ResourceManager.notifyWorkerFailed.runAsync |
From |
To |
|
Rename Variable gateway : TestingResourceManagerGatewayProxy to metricRegistry : MetricRegistry in method public testGrantAndRevokeLeadership() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerHATest |
From |
To |
|
Rename Variable registrationInstanceID : InstanceID to registrationId : InstanceID in method public notifySlotAvailable(resourceManagerLeaderId UUID, instanceID InstanceID, slotId SlotID) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Variable Type resourceManager : TestingResourceManager to resourceManager : ResourceManager<ResourceID> in method public testSlotAvailableRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotProtocolTest |
From |
To |
|
Change Variable Type worker : WorkerType to workerRegistration : WorkerRegistration<WorkerType> in method public run() : void in class org.apache.flink.runtime.resourcemanager.ResourceManager.notifyWorkerFailed.runAsync |
From |
To |
|
Change Variable Type gateway : TestingResourceManagerGatewayProxy to metricRegistry : MetricRegistry in method public testGrantAndRevokeLeadership() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerHATest |
From |
To |
|
Change Variable Type rm : ResourceManager<?> to rm : ResourceManagerRunner in method private shutdownInternally() : void in class org.apache.flink.runtime.minicluster.MiniCluster |
From |
To |
|
Change Variable Type resourceManagers : StandaloneResourceManager[] to resourceManagerRunners : ResourceManagerRunner[] in method protected startResourceManagers(configuration Configuration, haServices HighAvailabilityServices, metricRegistry MetricRegistry, numResourceManagers int, resourceManagerRpcServices RpcService[]) : ResourceManagerRunner[] in class org.apache.flink.runtime.minicluster.MiniCluster |
From |
To |
|
Rename Parameter error : Throwable to t : Throwable in method package onFatalErrorAsync(t Throwable) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Parameter infoMessageListenerAddress : String to address : String in method public unRegisterInfoMessageListener(address String) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Parameter infoMessageListenerAddress : String to address : String in method public registerInfoMessageListener(address String) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Parameter slotID : SlotID to slotId : SlotID in method public notifySlotAvailable(resourceManagerLeaderId UUID, instanceID InstanceID, slotId SlotID) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Parameter leaderSessionID : UUID to newLeaderSessionID : UUID in method public grantLeadership(newLeaderSessionID UUID) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |