|
Change Parameter Type gateway : Gateway to gateway : G in method private register(gateway G, attempt int, timeoutMillis long) : void in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Parameter Type leaderId : UUID to fencingToken : F in method public RetryingRegistration(log Logger, rpcService RpcService, targetName String, targetType Class<G>, targetAddress String, fencingToken F, initialRegistrationTimeout long, maxRegistrationTimeout long, delayOnError long, delayOnRefusedRegistration long) in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Parameter Type targetLeaderId : UUID to fencingToken : F in method public RegisteredRpcConnection(log Logger, targetAddress String, fencingToken F, executor Executor) in class org.apache.flink.runtime.registration.RegisteredRpcConnection |
From |
To |
|
Change Parameter Type leaderId : UUID to fencingToken : F in method public RetryingRegistration(log Logger, rpcService RpcService, targetName String, targetType Class<G>, targetAddress String, fencingToken F) in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Parameter Type targetType : Class<Gateway> to targetType : Class<G> in method public RetryingRegistration(log Logger, rpcService RpcService, targetName String, targetType Class<G>, targetAddress String, fencingToken F) in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Parameter Type gateway : Gateway to gateway : G in method private registerLater(gateway G, attempt int, timeoutMillis long, delay long) : void in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Parameter Type targetType : Class<Gateway> to targetType : Class<G> in method public RetryingRegistration(log Logger, rpcService RpcService, targetName String, targetType Class<G>, targetAddress String, fencingToken F, initialRegistrationTimeout long, maxRegistrationTimeout long, delayOnError long, delayOnRefusedRegistration long) in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Return Type CompletableFuture<Tuple2<Gateway,Success>> to CompletableFuture<Tuple2<G,S>> in method public getFuture() : CompletableFuture<Tuple2<G,S>> in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Return Type RetryingRegistration<TestRegistrationGateway,RetryingRegistrationTest.TestRegistrationSuccess> to RetryingRegistration<UUID,TestRegistrationGateway,RetryingRegistrationTest.TestRegistrationSuccess> in method protected generateRegistration() : RetryingRegistration<UUID,TestRegistrationGateway,RetryingRegistrationTest.TestRegistrationSuccess> in class org.apache.flink.runtime.registration.RegisteredRpcConnectionTest.TestRpcConnection |
From |
To |
|
Change Return Type RetryingRegistration<JobMasterGateway,JMTMRegistrationSuccess> to RetryingRegistration<UUID,JobMasterGateway,JMTMRegistrationSuccess> in method protected generateRegistration() : RetryingRegistration<UUID,JobMasterGateway,JMTMRegistrationSuccess> in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerLeaderListener.JobManagerRegisteredRpcConnection |
From |
To |
|
Change Return Type RetryingRegistration<ResourceManagerGateway,TaskExecutorRegistrationSuccess> to RetryingRegistration<UUID,ResourceManagerGateway,TaskExecutorRegistrationSuccess> in method protected generateRegistration() : RetryingRegistration<UUID,ResourceManagerGateway,TaskExecutorRegistrationSuccess> in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection |
From |
To |
|
Change Return Type RetryingRegistration<ResourceManagerGateway,JobMasterRegistrationSuccess> to RetryingRegistration<UUID,ResourceManagerGateway,JobMasterRegistrationSuccess> in method protected generateRegistration() : RetryingRegistration<UUID,ResourceManagerGateway,JobMasterRegistrationSuccess> in class org.apache.flink.runtime.jobmaster.JobMaster.ResourceManagerConnection |
From |
To |
|
Change Return Type RetryingRegistration<Gateway,Success> to RetryingRegistration<F,G,S> in method protected abstract generateRegistration() : RetryingRegistration<F,G,S> in class org.apache.flink.runtime.registration.RegisteredRpcConnection |
From |
To |
|
Change Return Type UUID to F in method public getTargetLeaderId() : F in class org.apache.flink.runtime.registration.RegisteredRpcConnection |
From |
To |
|
Change Return Type Gateway to G in method public getTargetGateway() : G in class org.apache.flink.runtime.registration.RegisteredRpcConnection |
From |
To |
|
Change Attribute Type targetGateway : Gateway to targetGateway : G in class org.apache.flink.runtime.registration.RegisteredRpcConnection |
From |
To |
|
Change Attribute Type targetLeaderId : UUID to fencingToken : F in class org.apache.flink.runtime.registration.RegisteredRpcConnection |
From |
To |
|
Change Attribute Type rpcConnection : RegisteredRpcConnection<JobMasterGateway,JMTMRegistrationSuccess> to rpcConnection : RegisteredRpcConnection<UUID,JobMasterGateway,JMTMRegistrationSuccess> in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerLeaderListener |
From |
To |
|
Change Attribute Type leaderId : UUID to fencingToken : F in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Attribute Type targetType : Class<Gateway> to targetType : Class<G> in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Attribute Type completionFuture : CompletableFuture<Tuple2<Gateway,Success>> to completionFuture : CompletableFuture<Tuple2<G,S>> in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Attribute Type pendingRegistration : RetryingRegistration<Gateway,Success> to pendingRegistration : RetryingRegistration<F,G,S> in class org.apache.flink.runtime.registration.RegisteredRpcConnection |
From |
To |
|
Rename Parameter leaderId : UUID to fencingToken : F in method public RetryingRegistration(log Logger, rpcService RpcService, targetName String, targetType Class<G>, targetAddress String, fencingToken F) in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Rename Parameter leaderId : UUID to fencingToken : F in method public RetryingRegistration(log Logger, rpcService RpcService, targetName String, targetType Class<G>, targetAddress String, fencingToken F, initialRegistrationTimeout long, maxRegistrationTimeout long, delayOnError long, delayOnRefusedRegistration long) in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Rename Parameter targetLeaderId : UUID to fencingToken : F in method public RegisteredRpcConnection(log Logger, targetAddress String, fencingToken F, executor Executor) in class org.apache.flink.runtime.registration.RegisteredRpcConnection |
From |
To |