|
Change Parameter Type terminationFuture : CompletableFuture<Boolean> to terminationFuture : CompletableFuture<Void> in method package AkkaInvocationHandler(address String, hostname String, rpcEndpoint ActorRef, timeout Time, maximumFramesize long, terminationFuture CompletableFuture<Void>) in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Parameter Type terminationFuture : CompletableFuture<Boolean> to terminationFuture : CompletableFuture<Void> in method public FencedAkkaInvocationHandler(address String, hostname String, rpcEndpoint ActorRef, timeout Time, maximumFramesize long, terminationFuture CompletableFuture<Void>, fencingTokenSupplier Supplier<F>) in class org.apache.flink.runtime.rpc.akka.FencedAkkaInvocationHandler |
From |
To |
|
Change Variable Type terminationFuture : CompletableFuture<Boolean> to terminationFuture : CompletableFuture<Void> in method public testJobResultRetrieval() : void in class org.apache.flink.runtime.dispatcher.MiniDispatcherTest |
From |
To |
|
Change Variable Type terminationFuture : CompletableFuture<Boolean> to terminationFuture : CompletableFuture<Void> in method public testPostStopExceptionPropagation() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type terminationFuture : CompletableFuture<Boolean> to terminationFuture : CompletableFuture<Void> in method public startServer(rpcEndpoint C) : RpcServer in class org.apache.flink.runtime.rpc.akka.AkkaRpcService |
From |
To |
|
Change Variable Type terminationFuture : CompletableFuture<Boolean> to terminationFuture : CompletableFuture<Void> in method public testActorTerminationWhenServiceShutdown() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type terminationFuture : CompletableFuture<Boolean> to terminationFuture : CompletableFuture<Void> in method public postStop() : void in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Variable Type terminationFuture : CompletableFuture<Boolean> to terminationFuture : CompletableFuture<Void> in method public testRpcEndpointTerminationFuture() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type jobManagerTerminationFuture : CompletableFuture<Boolean> to jobManagerTerminationFuture : CompletableFuture<Void> in method private shutdownInternally() : CompletableFuture<Void> in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |
|
Change Variable Type terminationFuture : CompletableFuture<Boolean> to terminationFuture : CompletableFuture<Void> in method public testPostStopExecutedByMainThread() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |