|
Change Return Type Future<Integer> to CompletableFuture<Integer> in method public doStuff() : CompletableFuture<Integer> in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest.ExceptionalGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public requestSlot(slotId SlotID, jobId JobID, allocationId AllocationID, targetAddress String, resourceManagerLeaderId UUID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Change Return Type Future<BlobKey> to CompletableFuture<BlobKey> in method public requestTaskManagerLog(timeout Time) : CompletableFuture<BlobKey> in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public getTerminationFuture() : CompletableFuture<Void> in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Return Type Future<V> to CompletableFuture<V> in method public callAsync(callable Callable<V>, callTimeout Time) : CompletableFuture<V> in class org.apache.flink.runtime.rpc.MainThreadExecutable |
From |
To |
|
Change Return Type Future<BlobKey> to CompletableFuture<BlobKey> in method public requestTaskManagerStdout(timeout Time) : CompletableFuture<BlobKey> in class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway |
From |
To |
|
Change Return Type Future<BlobKey> to CompletableFuture<BlobKey> in method private requestTaskManagerLog(request TaskManagerMessages.RequestTaskManagerLog, timeout Time) : CompletableFuture<BlobKey> in class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method public registerJobManager(resourceManagerLeaderId UUID, jobMasterLeaderId UUID, jobMasterResourceId ResourceID, jobMasterAddress String, jobID JobID, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Change Return Type Future<T> to CompletableFuture<T> in method public futureWithTimeout(timeoutMillis long) : CompletableFuture<T> in class org.apache.flink.runtime.rpc.TestingGatewayBase |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public submitTask(tdd TaskDeploymentDescriptor, leaderId UUID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public updateTaskExecutionState(leaderSessionID UUID, taskExecutionState TaskExecutionState) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Return Type Future<Integer> to CompletableFuture<Integer> in method public foobar() : CompletableFuture<Integer> in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest.DummyRpcGateway |
From |
To |
|
Change Return Type Future<BlobKey> to CompletableFuture<BlobKey> in method public requestTaskManagerLog(timeout Time) : CompletableFuture<BlobKey> in class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway |
From |
To |
|
Change Return Type Future<Collection<JobID>> to CompletableFuture<Collection<JobID>> in method public listJobs(timeout Time) : CompletableFuture<Collection<JobID>> in class org.apache.flink.runtime.dispatcher.DispatcherGateway |
From |
To |
|
Change Return Type Future<UUID> to CompletableFuture<UUID> in method public getLeaderIdFuture() : CompletableFuture<UUID> in class org.apache.flink.runtime.resourcemanager.JobLeaderIdService.JobLeaderIdListener |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public cancelTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Change Return Type Future<StackTraceSampleResponse> to CompletableFuture<StackTraceSampleResponse> in method public requestStackTraceSample(executionAttemptID ExecutionAttemptID, sampleId int, numSamples int, delayBetweenSamples Time, maxStackTraceDepth int, timeout Time) : CompletableFuture<StackTraceSampleResponse> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public cancelTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public cancelTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public getTerminationFuture() : CompletableFuture<Void> in class org.apache.flink.runtime.rpc.TestingSerialRpcService |
From |
To |
|
Change Return Type Future<ExecutionState> to CompletableFuture<ExecutionState> in method public requestPartitionState(leaderSessionID UUID, intermediateResultId IntermediateDataSetID, partitionId ResultPartitionID) : CompletableFuture<ExecutionState> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Return Type Future<T> to CompletableFuture<T> in method public execute(callable Callable<T>) : CompletableFuture<T> in class org.apache.flink.runtime.rpc.TestingSerialRpcService |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public requestSlot(resourceManagerLeaderID UUID, jobMasterLeaderID UUID, slotRequest SlotRequest, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public stopTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public getTerminationFuture() : CompletableFuture<Void> in class org.apache.flink.runtime.rpc.SelfGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public stopTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway |
From |
To |
|
Change Return Type Future<Boolean> to CompletableFuture<Boolean> in method public barfoo() : CompletableFuture<Boolean> in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest.WrongRpcGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public submitTask(tdd TaskDeploymentDescriptor, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method public registerTaskExecutor(resourceManagerLeaderId UUID, taskExecutorAddress String, taskExecutorResourceId ResourceID, slotReport SlotReport) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public cancelTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public scheduleOrUpdateConsumers(leaderSessionID UUID, partitionID ResultPartitionID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public updatePartitions(executionAttemptID ExecutionAttemptID, partitionInfos Iterable<PartitionInfo>, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public updatePartitions(executionAttemptID ExecutionAttemptID, partitionInfos Iterable<PartitionInfo>, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method public registerTaskExecutor(resourceManagerLeaderId UUID, taskExecutorAddress String, resourceID ResourceID, slotReport SlotReport, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Change Return Type Future<StackTrace> to CompletableFuture<StackTrace> in method public requestStackTrace(timeout Time) : CompletableFuture<StackTrace> in class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway |
From |
To |
|
Change Return Type Future<V> to CompletableFuture<V> in method public callAsync(callable Callable<V>, callTimeout Time) : CompletableFuture<V> in class org.apache.flink.runtime.rpc.TestingSerialRpcService.TestingSerialInvocationHandler |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public stopTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Return Type Future<Integer> to CompletableFuture<Integer> in method public getNumberOfRegisteredTaskManagers(leaderSessionId UUID) : CompletableFuture<Integer> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Change Return Type Future<C> to CompletableFuture<C> in method public connect(address String, clazz Class<C>) : CompletableFuture<C> in class org.apache.flink.runtime.rpc.akka.AkkaRpcService |
From |
To |
|
Change Return Type Future<KvStateLocation> to CompletableFuture<KvStateLocation> in method public lookupKvStateLocation(registrationName String) : CompletableFuture<KvStateLocation> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Return Type Future<StackTrace> to CompletableFuture<StackTrace> in method public requestStackTrace(timeout Time) : CompletableFuture<StackTrace> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway |
From |
To |
|
Change Return Type Future<String> to CompletableFuture<String> in method public getWasQuarantinedByFuture() : CompletableFuture<String> in class org.apache.flink.runtime.akka.QuarantineMonitorTest.TestingQuarantineHandler |
From |
To |
|
Change Return Type Future<SimpleSlot> to CompletableFuture<SimpleSlot> in method public allocateSlot(task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Return Type Future<StackTrace> to CompletableFuture<StackTrace> in method public requestStackTrace(timeout Time) : CompletableFuture<StackTrace> in class org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public cancelTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway |
From |
To |
|
Change Return Type Future<String> to CompletableFuture<String> in method public getHasQuarantinedFuture() : CompletableFuture<String> in class org.apache.flink.runtime.akka.QuarantineMonitorTest.TestingQuarantineHandler |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public updatePartitions(executionAttemptID ExecutionAttemptID, partitionInfos Iterable<PartitionInfo>, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Return Type Future<BlobKey> to CompletableFuture<BlobKey> in method public requestTaskManagerStdout(timeout Time) : CompletableFuture<BlobKey> in class org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway |
From |
To |
|
Change Return Type Future<T> to CompletableFuture<T> in method public execute(callable Callable<T>) : CompletableFuture<T> in class org.apache.flink.runtime.rpc.akka.AkkaRpcService |
From |
To |
|
Change Return Type Future<Boolean> to CompletableFuture<Boolean> in method public gotCanceled() : CompletableFuture<Boolean> in class org.apache.flink.runtime.taskmanager.TaskManagerTest.TestInvokableRecordCancel |
From |
To |
|
Change Return Type Future<StackTrace> to CompletableFuture<StackTrace> in method public requestStackTrace(timeout Time) : CompletableFuture<StackTrace> in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Return Type Future<StackTraceSampleResponse> to CompletableFuture<StackTraceSampleResponse> in method public requestStackTraceSample(executionAttemptID ExecutionAttemptID, sampleId int, numSamples int, delayBetweenSamples Time, maxStackTraceDepth int, timeout Time) : CompletableFuture<StackTraceSampleResponse> in class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public stopTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Change Return Type Future<V> to CompletableFuture<V> in method public callAsync(callable Callable<V>, callTimeout Time) : CompletableFuture<V> in class org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method public registerJobManager(resourceManagerLeaderId UUID, jobManagerLeaderId UUID, jobManagerResourceId ResourceID, jobManagerAddress String, jobId JobID) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Return Type Future<ClassloadingProps> to CompletableFuture<ClassloadingProps> in method public requestClassloadingProps() : CompletableFuture<ClassloadingProps> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public getTerminationFuture() : CompletableFuture<Void> in class org.apache.flink.runtime.taskexecutor.TaskManagerRunner |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public getTerminationFuture() : CompletableFuture<Void> in class org.apache.flink.runtime.rpc.RpcEndpoint |
From |
To |
|
Change Return Type Future<Iterable<SlotOffer>> to CompletableFuture<Iterable<SlotOffer>> in method public offerSlots(taskManagerId ResourceID, slots Iterable<SlotOffer>, leaderId UUID) : CompletableFuture<Iterable<SlotOffer>> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method public registerTaskManager(taskManagerRpcAddress String, taskManagerLocation TaskManagerLocation, leaderId UUID) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method public registrationCall(leaderId UUID, timeout long) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.registration.TestRegistrationGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public submitTask(tdd TaskDeploymentDescriptor, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway |
From |
To |
|
Change Return Type Future<V> to CompletableFuture<V> in method protected callAsync(callable Callable<V>, timeout Time) : CompletableFuture<V> in class org.apache.flink.runtime.rpc.RpcEndpoint |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public confirmCheckpoint(executionAttemptID ExecutionAttemptID, checkpointId long, checkpointTimestamp long) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Change Return Type Future<StackTraceSampleResponse> to CompletableFuture<StackTraceSampleResponse> in method public requestStackTraceSample(executionAttemptID ExecutionAttemptID, sampleId int, numSamples int, delayBetweenSamples Time, maxStackTraceDepth int, timeout Time) : CompletableFuture<StackTraceSampleResponse> in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Return Type Future<Iterable<SlotOffer>> to CompletableFuture<Iterable<SlotOffer>> in method public offerSlots(taskManagerId ResourceID, slots Iterable<SlotOffer>, leaderId UUID, timeout Time) : CompletableFuture<Iterable<SlotOffer>> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public getTerminationFuture() : CompletableFuture<Void> in class org.apache.flink.runtime.rpc.akka.AkkaRpcService |
From |
To |
|
Change Return Type Future<BlobKey> to CompletableFuture<BlobKey> in method public requestTaskManagerStdout(timeout Time) : CompletableFuture<BlobKey> in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Return Type Future<StackTraceSampleResponse> to CompletableFuture<StackTraceSampleResponse> in method public requestStackTraceSample(executionAttemptID ExecutionAttemptID, sampleId int, numSamples int, delayBetweenSamples Time, maxStackTraceDepth int, timeout Time) : CompletableFuture<StackTraceSampleResponse> in class org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public triggerCheckpoint(executionAttemptID ExecutionAttemptID, checkpointID long, checkpointTimestamp long, checkpointOptions CheckpointOptions) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Change Return Type Future<Integer> to CompletableFuture<Integer> in method public doStuff() : CompletableFuture<Integer> in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest.ExceptionalFutureEndpoint |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public stopTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway |
From |
To |
|
Change Return Type Future<T> to CompletableFuture<T> in method public execute(callable Callable<T>) : CompletableFuture<T> in class org.apache.flink.runtime.rpc.RpcService |
From |
To |
|
Change Return Type Future<SerializedInputSplit> to CompletableFuture<SerializedInputSplit> in method public requestNextInputSplit(leaderSessionID UUID, vertexID JobVertexID, executionAttempt ExecutionAttemptID) : CompletableFuture<SerializedInputSplit> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Return Type Future<RegistrationResponse> to CompletableFuture<RegistrationResponse> in method public registerTaskManager(taskManagerRpcAddress String, taskManagerLocation TaskManagerLocation, leaderId UUID, timeout Time) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public submitTask(tdd TaskDeploymentDescriptor, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public updatePartitions(executionAttemptID ExecutionAttemptID, partitionInfos Iterable<PartitionInfo>, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutorGateway |
From |
To |
|
Change Return Type Future<C> to CompletableFuture<C> in method public connect(address String, clazz Class<C>) : CompletableFuture<C> in class org.apache.flink.runtime.rpc.RpcService |
From |
To |
|
Change Return Type Future<UUID> to CompletableFuture<UUID> in method public getLeaderId(jobId JobID) : CompletableFuture<UUID> in class org.apache.flink.runtime.resourcemanager.JobLeaderIdService |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public getTerminationFuture() : CompletableFuture<Void> in class org.apache.flink.runtime.rpc.RpcService |
From |
To |
|
Change Return Type Future<C> to CompletableFuture<C> in method public connect(address String, clazz Class<C>) : CompletableFuture<C> in class org.apache.flink.runtime.rpc.TestingSerialRpcService |
From |
To |
|
Change Return Type Future<Iterable<SlotOffer>> to CompletableFuture<Iterable<SlotOffer>> in method public offerSlots(offers Iterable<Tuple2<AllocatedSlot,SlotOffer>>) : CompletableFuture<Iterable<SlotOffer>> in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Change Return Type Future<C> to CompletableFuture<C> in method public connect(address String, clazz Class<C>) : CompletableFuture<C> in class org.apache.flink.runtime.rpc.TestingRpcService |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public submitJob(jobGraph JobGraph, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.DispatcherGateway |
From |
To |
|
Change Return Type Future<SimpleSlot> to CompletableFuture<SimpleSlot> in method public allocateSlot(task ScheduledUnit, resources ResourceProfile, locationPreferences Iterable<TaskManagerLocation>, timeout Time) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Change Return Type Future<BlobKey> to CompletableFuture<BlobKey> in method public requestTaskManagerLog(timeout Time) : CompletableFuture<BlobKey> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway |
From |
To |
|
Change Return Type Future<BlobKey> to CompletableFuture<BlobKey> in method public requestTaskManagerLog(timeout Time) : CompletableFuture<BlobKey> in class org.apache.flink.runtime.jobmanager.slots.TaskManagerGateway |
From |
To |
|
Change Return Type Future<BlobKey> to CompletableFuture<BlobKey> in method public requestTaskManagerStdout(timeout Time) : CompletableFuture<BlobKey> in class org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public cancelTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.executiongraph.utils.NotCancelAckingTaskGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public submitTask(tdd TaskDeploymentDescriptor, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway |
From |
To |
|
Change Return Type Future<Boolean> to CompletableFuture<Boolean> in method public offerSlot(slot AllocatedSlot) : CompletableFuture<Boolean> in class org.apache.flink.runtime.instance.SlotPoolGateway |
From |
To |
|
Change Return Type Future<Acknowledge> to CompletableFuture<Acknowledge> in method public updatePartitions(executionAttemptID ExecutionAttemptID, partitionInfos Iterable<PartitionInfo>, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmanager.slots.ActorTaskManagerGateway |
From |
To |
|
Change Variable Type futureRpcGateway : Future<DummyRpcGateway> to futureRpcGateway : CompletableFuture<DummyRpcGateway> in method public testAddressResolution() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type future1 : Future<SimpleSlot> to future1 : CompletableFuture<SimpleSlot> in method public testReleaseResource() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type leaderIdFuture : Future<UUID> to leaderIdFuture : CompletableFuture<UUID> in method public jobTimeoutAfterLostLeadership() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type terminationFuture : Future<Void> to terminationFuture : CompletableFuture<Void> in method public testTerminationFuture() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcServiceTest |
From |
To |
|
Change Variable Type jobLeaderIdFuture : Future<UUID> to jobLeaderIdFuture : CompletableFuture<UUID> in method public registerJobManager(resourceManagerLeaderId UUID, jobManagerLeaderId UUID, jobManagerResourceId ResourceID, jobManagerAddress String, jobId JobID) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Variable Type quarantineFuture : Future<String> to quarantineFuture : CompletableFuture<String> in method public testWatcherQuarantining() : void in class org.apache.flink.runtime.akka.QuarantineMonitorTest |
From |
To |
|
Change Variable Type registration : Future<RegistrationResponse> to registration : CompletableFuture<RegistrationResponse> in method public registerJobMaster(jobMaster MockJobMaster) : void in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerTest.Context |
From |
To |
|
Change Variable Type duplicateFuture : Future<RegistrationResponse> to duplicateFuture : CompletableFuture<RegistrationResponse> in method public testRegisterTaskExecutor() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest |
From |
To |
|
Change Variable Type future : FlinkCompletableFuture<T> to future : CompletableFuture<T> in method public futureWithTimeout(timeoutMillis long) : CompletableFuture<T> in class org.apache.flink.runtime.rpc.TestingGatewayBase |
From |
To |
|
Change Variable Type future2 : Future<SimpleSlot> to future2 : CompletableFuture<SimpleSlot> in method public testReleaseResource() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type futureRpcGateway : Future<DummyRpcGateway> to futureRpcGateway : CompletableFuture<DummyRpcGateway> in method public testFailingAddressResolution() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type successfulFuture : Future<RegistrationResponse> to successfulFuture : CompletableFuture<RegistrationResponse> in method public testHeartbeatTimeoutWithJobManager() : void in class org.apache.flink.runtime.clusterframework.ResourceManagerTest |
From |
To |
|
Change Variable Type resourceManager : ResourceManager to resourceManager : ResourceManager<?> in method public testRegisterJobMasterWithFailureLeaderListener() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type future1 : Future<SimpleSlot> to future1 : CompletableFuture<SimpleSlot> in method public testAllocationFulfilledByReturnedSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type quarantineFuture : Future<String> to quarantineFuture : CompletableFuture<String> in method public testWatcheeQuarantined() : void in class org.apache.flink.runtime.akka.QuarantineMonitorTest |
From |
To |
|
Change Variable Type future1 : Future<SimpleSlot> to future1 : CompletableFuture<SimpleSlot> in method public testAllocateWithFreeSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type result : Future<Boolean> to result : CompletableFuture<Boolean> in method public testWrongGatewayEndpointConnection() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type slotRequestFuture2 : FlinkCompletableFuture<Acknowledge> to slotRequestFuture2 : CompletableFuture<Acknowledge> in method public testTaskManagerSlotRequestTimeoutHandling() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type slotRequestFuture1 : FlinkCompletableFuture<Acknowledge> to slotRequestFuture1 : CompletableFuture<Acknowledge> in method public testSlotReportWhileActiveSlotRequest() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type unMatchedLeaderFuture : Future<RegistrationResponse> to unMatchedLeaderFuture : CompletableFuture<RegistrationResponse> in method public testRegisterTaskExecutorWithUnmatchedLeaderSessionId() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest |
From |
To |
|
Change Variable Type terminationFuture : Future<Void> to terminationFuture : CompletableFuture<Void> in method public testPostStopExceptionPropagation() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type registrationResponseFuture : Future<RegistrationResponse> to registrationResponseFuture : CompletableFuture<RegistrationResponse> in method public registerJobManager(resourceManagerLeaderId UUID, jobManagerLeaderId UUID, jobManagerResourceId ResourceID, jobManagerAddress String, jobId JobID) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Variable Type future : Future<?> to future : CompletableFuture<?> in method private handleRpcInvocation(rpcInvocation RpcInvocation) : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActor |
From |
To |
|
Change Variable Type unMatchedLeaderFuture : Future<RegistrationResponse> to unMatchedLeaderFuture : CompletableFuture<RegistrationResponse> in method public testRegisterJobMasterWithUnmatchedLeaderSessionId1() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type cancelFuture : Future<Boolean> to cancelFuture : CompletableFuture<Boolean> in method public testFailingScheduleOrUpdateConsumersMessage() : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest |
From |
To |
|
Change Variable Type remoteGatewayFuture : Future<TestGateway> to remoteGatewayFuture : CompletableFuture<TestGateway> in method public testMaximumFramesizeRemoteMessageTransfer() : void in class org.apache.flink.runtime.rpc.akka.MessageSerializationTest |
From |
To |
|
Change Variable Type taskExecutorGatewayFuture : Future<TaskExecutorGateway> to taskExecutorGatewayFuture : CompletableFuture<TaskExecutorGateway> in method public registerTaskExecutor(resourceManagerLeaderId UUID, taskExecutorAddress String, taskExecutorResourceId ResourceID, slotReport SlotReport) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Variable Type successfulFuture : Future<RegistrationResponse> to successfulFuture : CompletableFuture<RegistrationResponse> in method public testHeartbeatTimeoutWithTaskExecutor() : void in class org.apache.flink.runtime.clusterframework.ResourceManagerTest |
From |
To |
|
Change Variable Type successfulFuture : Future<RegistrationResponse> to successfulFuture : CompletableFuture<RegistrationResponse> in method public testRegisterJobMaster() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type futureGateway : Future<WrongRpcGateway> to futureGateway : CompletableFuture<WrongRpcGateway> in method public testWrongGatewayEndpointConnection() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type resourceManager : ResourceManager to resourceManager : ResourceManager<?> in method public testRegisterJobMasterWithUnmatchedLeaderSessionId1() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type remoteGatewayFuture : Future<TestGateway> to remoteGatewayFuture : CompletableFuture<TestGateway> in method public testSerializableRemoteMessageTransfer() : void in class org.apache.flink.runtime.rpc.akka.MessageSerializationTest |
From |
To |
|
Change Variable Type terminationFuture : Future<Void> to terminationFuture : CompletableFuture<Void> in method public testRpcEndpointTerminationFuture() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type resourceManager : ResourceManager to resourceManager : ResourceManager<?> in method public testRegisterJobMaster() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type future : Future<TaskExecutorGateway> to future : CompletableFuture<TaskExecutorGateway> in method public testConnectFailure() : void in class org.apache.flink.runtime.rpc.RpcConnectionTest |
From |
To |
|
Change Variable Type terminationFuture : Future<Void> to terminationFuture : CompletableFuture<Void> in method public testPostStopExecutedByMainThread() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type future : Future<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public testSlotAllocationNoResourceManager() : void in class org.apache.flink.runtime.instance.SlotPoolRpcTest |
From |
To |
|
Change Variable Type remoteGatewayFuture : Future<TestGateway> to remoteGatewayFuture : CompletableFuture<TestGateway> in method public testNonSerializableRemoteMessageTransfer() : void in class org.apache.flink.runtime.rpc.akka.MessageSerializationTest |
From |
To |
|
Change Variable Type result : Future<Integer> to result : CompletableFuture<Integer> in method public testMessageDiscarding() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type future : Future<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public testAllocateSimpleSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type unMatchedLeaderFuture : Future<RegistrationResponse> to unMatchedLeaderFuture : CompletableFuture<RegistrationResponse> in method public testRegisterJobMasterWithUnmatchedLeaderSessionId2() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type result : FlinkCompletableFuture<RegistrationResponse> to result : CompletableFuture<RegistrationResponse> in method public testCancellation() : void in class org.apache.flink.runtime.registration.RetryingRegistrationTest |
From |
To |
|
Change Variable Type declineFuture : Future<RegistrationResponse> to declineFuture : CompletableFuture<RegistrationResponse> in method public testRegisterJobMasterWithFailureLeaderListener() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type future2 : Future<SimpleSlot> to future2 : CompletableFuture<SimpleSlot> in method public testAllocateWithFreeSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type slotRequestFuture1 : FlinkCompletableFuture<Acknowledge> to slotRequestFuture1 : CompletableFuture<Acknowledge> in method public testTaskManagerSlotRequestTimeoutHandling() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest |
From |
To |
|
Change Variable Type future2 : Future<SimpleSlot> to future2 : CompletableFuture<SimpleSlot> in method public testAllocationFulfilledByReturnedSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type acknowledgeFuture : Future<Acknowledge> to acknowledgeFuture : CompletableFuture<Acknowledge> in method public testJobSubmission() : void in class org.apache.flink.runtime.dispatcher.DispatcherTest |
From |
To |
|
Change Variable Type future : Future<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public testOfferSlot() : void in class org.apache.flink.runtime.instance.SlotPoolTest |
From |
To |
|
Change Variable Type futureInputSplit : Future<SerializedInputSplit> to futureInputSplit : CompletableFuture<SerializedInputSplit> in method public getNextInputSplit(userCodeClassLoader ClassLoader) : InputSplit in class org.apache.flink.runtime.taskexecutor.rpc.RpcInputSplitProvider |
From |
To |
|
Change Variable Type resourceManager : ResourceManager to resourceManager : ResourceManager<?> in method public testRegisterJobMasterWithUnmatchedLeaderSessionId2() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type successfulFuture : Future<RegistrationResponse> to successfulFuture : CompletableFuture<RegistrationResponse> in method public testRegisterTaskExecutor() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest |
From |
To |
|
Change Variable Type acknowledgeFuture : Future<Acknowledge> to acknowledgeFuture : CompletableFuture<Acknowledge> in method public notifyPartitionConsumable(jobId JobID, partitionId ResultPartitionID, taskActions TaskActions) : void in class org.apache.flink.runtime.taskexecutor.rpc.RpcResultPartitionConsumableNotifier |
From |
To |
|
Change Variable Type invalidAddressFuture : Future<RegistrationResponse> to invalidAddressFuture : CompletableFuture<RegistrationResponse> in method public testRegisterJobMasterFromInvalidAddress() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type registrationResponseFuture : Future<RegistrationResponse> to registrationResponseFuture : CompletableFuture<RegistrationResponse> in method public testSlotAllocation() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorITCase |
From |
To |
|
Change Variable Type result : Future<Integer> to result : CompletableFuture<Integer> in method public testExceptionPropagationFuturePiping() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type jobMasterGatewayFuture : Future<JobMasterGateway> to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public registerJobManager(resourceManagerLeaderId UUID, jobManagerLeaderId UUID, jobManagerResourceId ResourceID, jobManagerAddress String, jobId JobID) : CompletableFuture<RegistrationResponse> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Variable Type future : FlinkCompletableFuture<Integer> to future : CompletableFuture<Integer> in method public doStuff() : CompletableFuture<Integer> in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest.ExceptionalFutureEndpoint |
From |
To |
|
Change Variable Type result : Future<Integer> to result : CompletableFuture<Integer> in method public testExceptionPropagation() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest |
From |
To |
|
Change Variable Type leaderIdFuture : Future<UUID> to leaderIdFuture : CompletableFuture<UUID> in method public testRemovingJob() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type leaderIdFuture : Future<UUID> to leaderIdFuture : CompletableFuture<UUID> in method public testAddingJob() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type invalidAddressFuture : Future<RegistrationResponse> to invalidAddressFuture : CompletableFuture<RegistrationResponse> in method public testRegisterTaskExecutorFromInvalidAddress() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest |
From |
To |
|
Change Variable Type resourceManager : ResourceManager to resourceManager : ResourceManager<?> in method public testRegisterJobMasterFromInvalidAddress() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type completionFuture : Future<Boolean> to completionFuture : CompletableFuture<Boolean> in method public testTaskSubmission() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type result : Future<Integer> to result : CompletableFuture<Integer> in method public testExecuteCallable() : void in class org.apache.flink.runtime.rpc.akka.AkkaRpcServiceTest |
From |
To |