|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method protected invokeRegistration(resourceManager ResourceManagerGateway, leaderId UUID, timeoutMillis long) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection.ResourceManagerRegistration |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method protected invokeRegistration(gateway JobMasterGateway, leaderId UUID, timeoutMillis long) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.taskexecutor.JobLeaderService.JobManagerRetryingRegistration |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method protected invokeRegistration(gateway TestRegistrationGateway, leaderId UUID, timeoutMillis long) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.registration.RetryingRegistrationTest.TestRetryingRegistration |
From |
To |
|
Change Return Type Future<Tuple2<Gateway,Success>> to CompletableFuture<Tuple2<Gateway,Success>> in method public getFuture() : CompletableFuture<Tuple2<Gateway,Success>> in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method protected abstract invokeRegistration(gateway Gateway, leaderId UUID, timeoutMillis long) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Variable Type future : Future<?> to future : CompletableFuture<?> in method public testPropagateFailures() : void in class org.apache.flink.runtime.registration.RetryingRegistrationTest |
From |
To |
|
Change Variable Type future : Future<Tuple2<TestRegistrationGateway,TestRegistrationSuccess>> to future : CompletableFuture<Tuple2<TestRegistrationGateway,TestRegistrationSuccess>> in method public testDecline() : void in class org.apache.flink.runtime.registration.RetryingRegistrationTest |
From |
To |
|
Change Variable Type resourceManagerFuture : Future<Gateway> to resourceManagerFuture : CompletableFuture<Gateway> in method public startRegistration() : void in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Variable Type registrationFuture : Future<RegistrationResponse> to registrationFuture : CompletableFuture<RegistrationResponse> in method private register(gateway Gateway, attempt int, timeoutMillis long) : void in class org.apache.flink.runtime.registration.RetryingRegistration |
From |
To |
|
Change Variable Type future : Future<Tuple2<TestRegistrationGateway,TestRegistrationSuccess>> to future : CompletableFuture<Tuple2<TestRegistrationGateway,TestRegistrationSuccess>> in method public testSimpleSuccessfulRegistration() : void in class org.apache.flink.runtime.registration.RetryingRegistrationTest |
From |
To |
|
Change Variable Type future : Future<Tuple2<TestRegistrationGateway,TestRegistrationSuccess>> to future : CompletableFuture<Tuple2<TestRegistrationGateway,TestRegistrationSuccess>> in method public testRetriesOnTimeouts() : void in class org.apache.flink.runtime.registration.RetryingRegistrationTest |
From |
To |
|
Change Variable Type future : Future<Tuple2<TestRegistrationGateway,TestRegistrationSuccess>> to future : CompletableFuture<Tuple2<TestRegistrationGateway,TestRegistrationSuccess>> in method public testRetryOnError() : void in class org.apache.flink.runtime.registration.RetryingRegistrationTest |
From |
To |
|
Change Variable Type future : Future<Tuple2<Gateway,Success>> to future : CompletableFuture<Tuple2<Gateway,Success>> in method public start() : void in class org.apache.flink.runtime.registration.RegisteredRpcConnection |
From |
To |