|
Change Parameter Type leaderId : UUID to fencingToken : ResourceManagerId in method protected invokeRegistration(resourceManager ResourceManagerGateway, fencingToken ResourceManagerId, timeoutMillis long) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection.ResourceManagerRegistration |
From |
To |
|
Change Parameter Type jobMasterLeaderRetrievalService : TestingLeaderRetrievalService to jobMasterLeaderRetrievalService : LeaderRetrievalService in method private createAndStartResourceManager(resourceManagerLeaderElectionService LeaderElectionService, jobID JobID, jobMasterLeaderRetrievalService LeaderRetrievalService, fatalErrorHandler FatalErrorHandler) : ResourceManager in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Parameter Type resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public requestSlot(slotId SlotID, jobId JobID, allocationId AllocationID, targetAddress String, resourceManagerId ResourceManagerId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Change Parameter Type resourceManagerLeaderElectionService : TestingLeaderElectionService to resourceManagerLeaderElectionService : LeaderElectionService in method private createAndStartResourceManager(resourceManagerLeaderElectionService LeaderElectionService, jobID JobID, jobMasterLeaderRetrievalService LeaderRetrievalService, fatalErrorHandler FatalErrorHandler) : ResourceManager in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Parameter Type leaderId : UUID to resourceManagerId : ResourceManagerId in method package ResourceManagerRegistration(log Logger, rpcService RpcService, targetAddress String, resourceManagerId ResourceManagerId, taskExecutorAddress String, resourceID ResourceID, slotReport SlotReport) in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection.ResourceManagerRegistration |
From |
To |
|
Change Parameter Type resourceManagerLeaderID : UUID to resourceManagerId : ResourceManagerId in method package ResourceManagerConnection(log Logger, jobID JobID, jobManagerResourceID ResourceID, jobManagerRpcAddress String, jobManagerLeaderID UUID, resourceManagerAddress String, resourceManagerId ResourceManagerId, executor Executor) in class org.apache.flink.runtime.jobmaster.JobMaster.ResourceManagerConnection |
From |
To |
|
Change Parameter Type resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public JobMasterRegistrationSuccess(heartbeatInterval long, resourceManagerId ResourceManagerId, resourceManagerResourceId ResourceID) in class org.apache.flink.runtime.jobmaster.JobMasterRegistrationSuccess |
From |
To |
|
Change Parameter Type rmLeaderElectionService : TestingLeaderElectionService to rmLeaderElectionService : LeaderElectionService in method private createAndStartResourceManager(rmLeaderElectionService LeaderElectionService, fatalErrorHandler FatalErrorHandler) : StandaloneResourceManager in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest |
From |
To |
|
Change Parameter Type rmLeaderId : UUID to resourceManagerId : ResourceManagerId in method public requestSlot(slotId SlotID, jobId JobID, allocationId AllocationID, targetAddress String, resourceManagerId ResourceManagerId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Parameter Type resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public TaskExecutorToResourceManagerConnection(log Logger, rpcService RpcService, taskManagerAddress String, taskManagerResourceId ResourceID, slotReport SlotReport, resourceManagerAddress String, resourceManagerId ResourceManagerId, executor Executor, registrationListener RegistrationConnectionListener<TaskExecutorRegistrationSuccess>) in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection |
From |
To |
|
Change Parameter Type resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public disconnectResourceManager(jobManagerLeaderId UUID, resourceManagerId ResourceManagerId, cause Exception) : void in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Parameter Type newLeaderId : UUID to newResourceManagerId : ResourceManagerId in method private notifyOfNewResourceManagerLeader(newLeaderAddress String, newResourceManagerId ResourceManagerId) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Parameter Type leaderId : UUID to resourceManagerId : ResourceManagerId in method private createSlotManager(resourceManagerId ResourceManagerId, resourceManagerActions ResourceManagerActions) : SlotManager in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Parameter Type newLeaderId : UUID to newResourceManagerId : ResourceManagerId in method public start(newResourceManagerId ResourceManagerId, newMainThreadExecutor Executor, newResourceManagerActions ResourceManagerActions) : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager |
From |
To |
|
Change Parameter Type resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public disconnectResourceManager(jobManagerLeaderId UUID, resourceManagerId ResourceManagerId, cause Exception) : void in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Parameter Type resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method private notifyOfNewResourceManagerLeader(resourceManagerAddress String, resourceManagerId ResourceManagerId) : void in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Rename Variable declineFuture : CompletableFuture<RegistrationResponse> to registrationFuture : CompletableFuture<RegistrationResponse> in method public testRegisterJobMasterWithFailureLeaderListener() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testUnregisterPendingSlotRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method private establishResourceManagerConnection(success JobMasterRegistrationSuccess) : void in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testFreeSlot() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTaskManagerTimeout() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotRequestWithoutFreeSlots() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotRequestTimeout() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotRequestWithResourceAllocationFailure() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testUpdateSlotReport() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotReportWhileActiveSlotRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotRequestWithFreeSlot() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testDuplicatePendingSlotRequestAfterSuccessfulAllocation() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable rmLeaderId : UUID to resourceManagerId : ResourceManagerId in method public testHeartbeatTimeoutWithResourceManager() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTaskManagerUnregistration() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTaskManagerSlotRequestTimeoutHandling() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testDuplicatePendingSlotRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testDuplicatePendingSlotRequestAfterSlotReport() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTimeoutForUnusedTaskManager() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testFulfillingPendingSlotRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTaskManagerRegistration() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testAcceptingDuplicateSlotRequestAfterAllocationRelease() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testRejectAllocationRequestsForOutOfSyncSlots() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Rename Variable leaderId : UUID to resourceManagerId : ResourceManagerId in method public testReceivingUnknownSlotReport() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Return Type UUID to CompletableFuture<UUID> in method private grantLeadership(leaderElectionService TestingLeaderElectionService) : CompletableFuture<UUID> in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest |
From |
To |
|
Change Return Type RetryingRegistration<UUID,ResourceManagerGateway,JobMasterRegistrationSuccess> to RetryingRegistration<ResourceManagerId,ResourceManagerGateway,JobMasterRegistrationSuccess> in method protected generateRegistration() : RetryingRegistration<ResourceManagerId,ResourceManagerGateway,JobMasterRegistrationSuccess> in class org.apache.flink.runtime.jobmaster.JobMaster.ResourceManagerConnection |
From |
To |
|
Change Return Type RetryingRegistration<UUID,ResourceManagerGateway,TaskExecutorRegistrationSuccess> to RetryingRegistration<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess> in method protected generateRegistration() : RetryingRegistration<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess> in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTaskManagerRegistration() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testAcceptingDuplicateSlotRequestAfterAllocationRelease() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testReceivingUnknownSlotReport() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type revokedLeaderIdFuture : CompletableFuture<UUID> to revokedLeaderIdFuture : CompletableFuture<ResourceManagerId> in method public testGrantAndRevokeLeadership() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerHATest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testRejectAllocationRequestsForOutOfSyncSlots() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testUnregisterPendingSlotRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testFreeSlot() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method private establishResourceManagerConnection(success JobMasterRegistrationSuccess) : void in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTaskManagerTimeout() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotRequestWithoutFreeSlots() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotRequestTimeout() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotRequestWithResourceAllocationFailure() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testUpdateSlotReport() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotReportWhileActiveSlotRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testSlotRequestWithFreeSlot() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testDuplicatePendingSlotRequestAfterSuccessfulAllocation() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type rmLeaderId : UUID to resourceManagerId : ResourceManagerId in method public testHeartbeatTimeoutWithResourceManager() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTaskManagerUnregistration() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTaskManagerSlotRequestTimeoutHandling() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testDuplicatePendingSlotRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testDuplicatePendingSlotRequestAfterSlotReport() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testFulfillingPendingSlotRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type leaderId : UUID to resourceManagerId : ResourceManagerId in method public testTimeoutForUnusedTaskManager() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Parameter leaderId : UUID to resourceManagerId : ResourceManagerId in method private createSlotManager(resourceManagerId ResourceManagerId, resourceManagerActions ResourceManagerActions) : SlotManager in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Rename Parameter newLeaderId : UUID to newResourceManagerId : ResourceManagerId in method public start(newResourceManagerId ResourceManagerId, newMainThreadExecutor Executor, newResourceManagerActions ResourceManagerActions) : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager |
From |
To |
|
Rename Parameter leaderId : UUID to resourceManagerId : ResourceManagerId in method package ResourceManagerRegistration(log Logger, rpcService RpcService, targetAddress String, resourceManagerId ResourceManagerId, taskExecutorAddress String, resourceID ResourceID, slotReport SlotReport) in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection.ResourceManagerRegistration |
From |
To |
|
Rename Parameter resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public JobMasterRegistrationSuccess(heartbeatInterval long, resourceManagerId ResourceManagerId, resourceManagerResourceId ResourceID) in class org.apache.flink.runtime.jobmaster.JobMasterRegistrationSuccess |
From |
To |
|
Rename Parameter resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public TaskExecutorToResourceManagerConnection(log Logger, rpcService RpcService, taskManagerAddress String, taskManagerResourceId ResourceID, slotReport SlotReport, resourceManagerAddress String, resourceManagerId ResourceManagerId, executor Executor, registrationListener RegistrationConnectionListener<TaskExecutorRegistrationSuccess>) in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection |
From |
To |
|
Rename Parameter newLeaderId : UUID to newResourceManagerId : ResourceManagerId in method private notifyOfNewResourceManagerLeader(newLeaderAddress String, newResourceManagerId ResourceManagerId) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Rename Parameter resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public requestSlot(slotId SlotID, jobId JobID, allocationId AllocationID, targetAddress String, resourceManagerId ResourceManagerId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Rename Parameter jobID : JobID to jobId : JobID in method public registerJobManager(jobMasterLeaderId UUID, jobMasterResourceId ResourceID, jobMasterAddress String, jobId JobID, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Rename Parameter resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public disconnectResourceManager(jobManagerLeaderId UUID, resourceManagerId ResourceManagerId, cause Exception) : void in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Rename Parameter resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method private notifyOfNewResourceManagerLeader(resourceManagerAddress String, resourceManagerId ResourceManagerId) : void in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Rename Parameter resourceManagerLeaderID : UUID to resourceManagerId : ResourceManagerId in method package ResourceManagerConnection(log Logger, jobID JobID, jobManagerResourceID ResourceID, jobManagerRpcAddress String, jobManagerLeaderID UUID, resourceManagerAddress String, resourceManagerId ResourceManagerId, executor Executor) in class org.apache.flink.runtime.jobmaster.JobMaster.ResourceManagerConnection |
From |
To |
|
Rename Parameter rmLeaderId : UUID to resourceManagerId : ResourceManagerId in method public requestSlot(slotId SlotID, jobId JobID, allocationId AllocationID, targetAddress String, resourceManagerId ResourceManagerId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Rename Parameter leaderId : UUID to fencingToken : ResourceManagerId in method protected invokeRegistration(resourceManager ResourceManagerGateway, fencingToken ResourceManagerId, timeoutMillis long) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection.ResourceManagerRegistration |
From |
To |
|
Rename Parameter resourceManagerLeaderId : UUID to resourceManagerId : ResourceManagerId in method public disconnectResourceManager(jobManagerLeaderId UUID, resourceManagerId ResourceManagerId, cause Exception) : void in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |