|
Change Parameter Type oldJobLeaderId : UUID to oldJobMasterId : JobMasterId in method protected jobLeaderLostLeadership(jobId JobID, oldJobMasterId JobMasterId) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Parameter Type jobMasterLeaderId : UUID to jobMasterId : JobMasterId in method public registerJobManager(jobMasterId JobMasterId, jobMasterResourceId ResourceID, jobMasterAddress String, jobId JobID, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Change Parameter Type jobManagerLeaderId : UUID to jobMasterId : JobMasterId in method public submitTask(tdd TaskDeploymentDescriptor, jobMasterId JobMasterId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Parameter Type jobManagerLeaderID : UUID to jobMasterId : JobMasterId in method package ResourceManagerConnection(log Logger, jobID JobID, jobManagerResourceID ResourceID, jobManagerRpcAddress String, jobMasterId JobMasterId, resourceManagerAddress String, resourceManagerId ResourceManagerId, executor Executor) in class org.apache.flink.runtime.jobmaster.JobMaster.ResourceManagerConnection |
From |
To |
|
Change Parameter Type jobManagerLeaderId : UUID to jobMasterId : JobMasterId in method public registerJobManager(jobMasterId JobMasterId, jobManagerResourceId ResourceID, jobManagerAddress String, jobId JobID, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Parameter Type oldJobLeaderId : UUID to oldJobMasterId : JobMasterId in method public jobLeaderLostLeadership(jobId JobID, oldJobMasterId JobMasterId) : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdActions |
From |
To |
|
Change Parameter Type newLeaderSessionId : UUID to newJobMasterId : JobMasterId in method private startJobExecution(newJobMasterId JobMasterId) : Acknowledge in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Parameter Type leaderId : UUID to jobMasterId : JobMasterId in method private isJobManagerConnectionValid(jobId JobID, jobMasterId JobMasterId) : boolean in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Parameter Type jobMasterLeaderID : UUID to jobMasterId : JobMasterId in method public requestSlot(jobMasterId JobMasterId, slotRequest SlotRequest, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Change Parameter Type jobMasterLeaderID : UUID to jobMasterId : JobMasterId in method public requestSlot(jobMasterId JobMasterId, slotRequest SlotRequest, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Parameter Type leaderId : UUID to jobMasterId : JobMasterId in method public RpcTaskManagerGateway(taskExecutorGateway TaskExecutorGateway, jobMasterId JobMasterId) in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Parameter Type leaderSessionID : UUID to newJobMasterId : JobMasterId in method public start(newJobMasterId JobMasterId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Parameter Type newJobManagerLeaderId : UUID to jobMasterId : JobMasterId in method public start(jobMasterId JobMasterId, newJobManagerAddress String) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Parameter Type leaderId : UUID to jobMasterId : JobMasterId in method package JobManagerRetryingRegistration(log Logger, rpcService RpcService, targetName String, targetType Class<JobMasterGateway>, targetAddress String, jobMasterId JobMasterId, taskManagerRpcAddress String, taskManagerLocation TaskManagerLocation) in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerRetryingRegistration |
From |
To |
|
Change Parameter Type leaderId : UUID to jobMasterId : JobMasterId in method public submitTask(tdd TaskDeploymentDescriptor, jobMasterId JobMasterId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Change Parameter Type targetLeaderId : UUID to jobMasterId : JobMasterId in method package JobManagerRegisteredRpcConnection(log Logger, targetAddress String, jobMasterId JobMasterId, executor Executor) in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerLeaderListener.JobManagerRegisteredRpcConnection |
From |
To |
|
Change Parameter Type oldJobLeaderId : UUID to oldJobMasterId : JobMasterId in method public jobLeaderLostLeadership(jobId JobID, oldJobMasterId JobMasterId) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager.JobLeaderIdActionsImpl |
From |
To |
|
Change Parameter Type leaderId : UUID to jobMasterId : JobMasterId in method protected invokeRegistration(gateway JobMasterGateway, jobMasterId JobMasterId, timeoutMillis long) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerRetryingRegistration |
From |
To |
|
Rename Variable jmLeaderId : UUID to jobMasterId : JobMasterId in method public testSlotAllocation() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorITCase |
From |
To |
|
Rename Variable jobManagerLeaderId : UUID to jobMasterId : JobMasterId in method public testSubmitTaskBeforeAcceptSlot() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Rename Variable jmLeaderID : UUID to jobMasterId : JobMasterId in method public testRegisterJobMasterWithUnmatchedLeaderSessionId1() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Rename Variable leaderSessionID2 : UUID to jobMasterId2 : JobMasterId in method public testRegainLeadership() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Rename Variable leaderSessionID : UUID to jobMasterId : JobMasterId in method public testJobFailed() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Rename Variable jmLeaderId : UUID to jobMasterId : JobMasterId in method public testHeartbeatTimeoutWithTaskManager() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest |
From |
To |
|
Rename Variable jobLeaderIdFuture : CompletableFuture<UUID> to jobMasterIdFuture : CompletableFuture<JobMasterId> in method public registerJobManager(jobMasterId JobMasterId, jobManagerResourceId ResourceID, jobManagerAddress String, jobId JobID, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Variable jobManagerLeaderId : UUID to jobMasterId : JobMasterId in method protected closeJobManagerConnection(jobId JobID, cause Exception) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Variable jmLeaderID : UUID to jobMasterId : JobMasterId in method public testRegisterJobMaster() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Rename Variable leaderSessionID : UUID to jobMasterId : JobMasterId in method public testRegainLeadership() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Rename Variable leaderSessionID : UUID to jobMasterId : JobMasterId in method public testJobFinished() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Rename Variable differentLeaderSessionID : UUID to differentJobMasterId : JobMasterId in method public testRegisterJobMasterWithUnmatchedLeaderSessionId2() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Rename Variable leaderSessionID : UUID to jobMasterId : JobMasterId in method public testLeadershipRevoked() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Rename Variable jmLeaderId : UUID to jobMasterId : JobMasterId in method public testHeartbeatTimeoutWithJobManager() : void in class org.apache.flink.runtime.clusterframework.ResourceManagerTest |
From |
To |
|
Rename Variable jmLeaderId : UUID to jobMasterId : JobMasterId in method public testHeartbeatTimeoutWithResourceManager() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest |
From |
To |
|
Rename Variable leaderId : UUID to jobMasterId : JobMasterId in method private offerSlotsToJobManager(jobId JobID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Variable Type jmLeaderId : UUID to jobMasterId : JobMasterId in method public testSlotAllocation() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorITCase |
From |
To |
|
Change Variable Type leaderIdFuture : CompletableFuture<UUID> to leaderIdFuture : CompletableFuture<JobMasterId> in method public testAddingJob() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type jobManagerLeaderId : UUID to jobMasterId : JobMasterId in method public testSubmitTaskBeforeAcceptSlot() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type leaderSessionID2 : UUID to jobMasterId2 : JobMasterId in method public testRegainLeadership() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Change Variable Type jmLeaderID : UUID to jobMasterId : JobMasterId in method public testRegisterJobMasterWithUnmatchedLeaderSessionId1() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type leaderSessionID : UUID to jobMasterId : JobMasterId in method public testJobFailed() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Change Variable Type jmLeaderId : UUID to jobMasterId : JobMasterId in method public testHeartbeatTimeoutWithTaskManager() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest |
From |
To |
|
Change Variable Type jobLeaderIdFuture : CompletableFuture<UUID> to jobMasterIdFuture : CompletableFuture<JobMasterId> in method public registerJobManager(jobMasterId JobMasterId, jobManagerResourceId ResourceID, jobManagerAddress String, jobId JobID, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Variable Type jobManagerLeaderId : UUID to jobMasterId : JobMasterId in method protected closeJobManagerConnection(jobId JobID, cause Exception) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Variable Type leaderSessionID : UUID to jobMasterId : JobMasterId in method public testRegainLeadership() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Change Variable Type jmLeaderID : UUID to jobMasterId : JobMasterId in method public testRegisterJobMaster() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type leaderIdFuture : CompletableFuture<UUID> to leaderIdFuture : CompletableFuture<JobMasterId> in method public jobTimeoutAfterLostLeadership() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type leaderSessionID : UUID to jobMasterId : JobMasterId in method public testJobFinished() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Change Variable Type differentLeaderSessionID : UUID to differentJobMasterId : JobMasterId in method public testRegisterJobMasterWithUnmatchedLeaderSessionId2() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type leaderIdFuture : CompletableFuture<UUID> to leaderIdFuture : CompletableFuture<JobMasterId> in method public testRemovingJob() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type leaderSessionID : UUID to jobMasterId : JobMasterId in method public testLeadershipRevoked() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunnerMockTest |
From |
To |
|
Change Variable Type jmLeaderId : UUID to jobMasterId : JobMasterId in method public testHeartbeatTimeoutWithJobManager() : void in class org.apache.flink.runtime.clusterframework.ResourceManagerTest |
From |
To |
|
Change Variable Type jmLeaderId : UUID to jobMasterId : JobMasterId in method public testHeartbeatTimeoutWithResourceManager() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest |
From |
To |
|
Change Variable Type leaderId : UUID to jobMasterId : JobMasterId in method private offerSlotsToJobManager(jobId JobID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Attribute Type jobManagerLeaderId : UUID to jobMasterId : JobMasterId in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Attribute Type leaderId : UUID to jobMasterId : JobMasterId in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Attribute Type currentLeaderId : UUID to currentJobMasterId : JobMasterId in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerLeaderListener |
From |
To |
|
Change Attribute Type jobManagerLeaderID : UUID to jobMasterId : JobMasterId in class org.apache.flink.runtime.jobmaster.JobMaster.ResourceManagerConnection |
From |
To |
|
Change Attribute Type leaderSessionID : UUID to jobMasterId : JobMasterId in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerTest.Context.MockJobMaster |
From |
To |
|
Change Attribute Type rpcConnection : RegisteredRpcConnection<UUID,JobMasterGateway,JMTMRegistrationSuccess> to rpcConnection : RegisteredRpcConnection<JobMasterId,JobMasterGateway,JMTMRegistrationSuccess> in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerLeaderListener |
From |
To |
|
Rename Parameter newLeaderSessionId : UUID to newJobMasterId : JobMasterId in method private startJobExecution(newJobMasterId JobMasterId) : Acknowledge in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Rename Parameter jobMasterLeaderID : UUID to jobMasterId : JobMasterId in method public requestSlot(jobMasterId JobMasterId, slotRequest SlotRequest, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Parameter leaderId : UUID to jobMasterId : JobMasterId in method public RpcTaskManagerGateway(taskExecutorGateway TaskExecutorGateway, jobMasterId JobMasterId) in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Rename Parameter jobManagerLeaderId : UUID to jobMasterId : JobMasterId in method public submitTask(tdd TaskDeploymentDescriptor, jobMasterId JobMasterId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Rename Parameter newJobManagerLeaderId : UUID to jobMasterId : JobMasterId in method public start(jobMasterId JobMasterId, newJobManagerAddress String) : void in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Rename Parameter leaderId : UUID to jobMasterId : JobMasterId in method public submitTask(tdd TaskDeploymentDescriptor, jobMasterId JobMasterId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Rename Parameter targetLeaderId : UUID to jobMasterId : JobMasterId in method package JobManagerRegisteredRpcConnection(log Logger, targetAddress String, jobMasterId JobMasterId, executor Executor) in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerLeaderListener.JobManagerRegisteredRpcConnection |
From |
To |
|
Rename Parameter oldJobLeaderId : UUID to oldJobMasterId : JobMasterId in method public jobLeaderLostLeadership(jobId JobID, oldJobMasterId JobMasterId) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager.JobLeaderIdActionsImpl |
From |
To |
|
Rename Parameter leaderId : UUID to jobMasterId : JobMasterId in method protected invokeRegistration(gateway JobMasterGateway, jobMasterId JobMasterId, timeoutMillis long) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerRetryingRegistration |
From |
To |
|
Rename Parameter leaderId : UUID to jobMasterId : JobMasterId in method private isJobManagerConnectionValid(jobId JobID, jobMasterId JobMasterId) : boolean in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Rename Parameter oldJobLeaderId : UUID to oldJobMasterId : JobMasterId in method protected jobLeaderLostLeadership(jobId JobID, oldJobMasterId JobMasterId) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Parameter jobMasterLeaderID : UUID to jobMasterId : JobMasterId in method public requestSlot(jobMasterId JobMasterId, slotRequest SlotRequest, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Rename Parameter jobMasterLeaderId : UUID to jobMasterId : JobMasterId in method public registerJobManager(jobMasterId JobMasterId, jobMasterResourceId ResourceID, jobMasterAddress String, jobId JobID, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Rename Parameter leaderSessionID : UUID to newJobMasterId : JobMasterId in method public start(newJobMasterId JobMasterId, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Rename Parameter jobManagerLeaderID : UUID to jobMasterId : JobMasterId in method package ResourceManagerConnection(log Logger, jobID JobID, jobManagerResourceID ResourceID, jobManagerRpcAddress String, jobMasterId JobMasterId, resourceManagerAddress String, resourceManagerId ResourceManagerId, executor Executor) in class org.apache.flink.runtime.jobmaster.JobMaster.ResourceManagerConnection |
From |
To |
|
Rename Parameter jobManagerLeaderId : UUID to jobMasterId : JobMasterId in method public registerJobManager(jobMasterId JobMasterId, jobManagerResourceId ResourceID, jobManagerAddress String, jobId JobID, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Parameter oldJobLeaderId : UUID to oldJobMasterId : JobMasterId in method public jobLeaderLostLeadership(jobId JobID, oldJobMasterId JobMasterId) : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdActions |
From |
To |
|
Rename Parameter leaderId : UUID to jobMasterId : JobMasterId in method package JobManagerRetryingRegistration(log Logger, rpcService RpcService, targetName String, targetType Class<JobMasterGateway>, targetAddress String, jobMasterId JobMasterId, taskManagerRpcAddress String, taskManagerLocation TaskManagerLocation) in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerRetryingRegistration |
From |
To |