|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public stopTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public confirmCheckpoint(executionAttemptID ExecutionAttemptID, checkpointId long, checkpointTimestamp long) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public requestSlot(jobMasterLeaderID UUID, resourceManagerLeaderID UUID, slotRequest SlotRequest, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public updatePartitions(executionAttemptID ExecutionAttemptID, partitionInfos Iterable<PartitionInfo>, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Return Type 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.TaskExecutor |
From |
To |
|
Change Return Type ClassloadingProps to CompletableFuture<ClassloadingProps> in method public requestClassloadingProps() : CompletableFuture<ClassloadingProps> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Return Type C to RpcServer in method public startServer(rpcEndpoint C) : RpcServer in class org.apache.flink.runtime.rpc.akka.AkkaRpcService |
From |
To |
|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public updateTaskExecutionState(leaderSessionID UUID, taskExecutionState TaskExecutionState) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Return Type Integer to CompletableFuture<Integer> in method public getNumberOfRegisteredTaskManagers(requestLeaderSessionId UUID) : CompletableFuture<Integer> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Return Type ExecutionState to CompletableFuture<ExecutionState> in method public requestPartitionState(leaderSessionID UUID, intermediateResultId IntermediateDataSetID, resultPartitionId ResultPartitionID) : CompletableFuture<ExecutionState> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Return Type CompletableFuture<Iterable<SlotOffer>> to CompletableFuture<Collection<SlotOffer>> in method public offerSlots(taskManagerId ResourceID, slots Iterable<SlotOffer>, leaderId UUID, timeout Time) : CompletableFuture<Collection<SlotOffer>> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Return Type C to RpcServer in method public startServer(rpcEndpoint C) : RpcServer in class org.apache.flink.runtime.rpc.RpcService |
From |
To |
|
Change Return Type SerializedInputSplit to CompletableFuture<SerializedInputSplit> in method public requestNextInputSplit(leaderSessionID UUID, vertexID JobVertexID, executionAttempt ExecutionAttemptID) : CompletableFuture<SerializedInputSplit> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public cancelTask(executionAttemptID ExecutionAttemptID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Return Type int to CompletableFuture<Integer> in method public foobar() : CompletableFuture<Integer> in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest.DummyRpcEndpoint |
From |
To |
|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public submitTask(tdd TaskDeploymentDescriptor, jobManagerLeaderId UUID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public submitJob(jobGraph JobGraph, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Return Type boolean to CompletableFuture<Boolean> in method public offerSlot(slot AllocatedSlot) : CompletableFuture<Boolean> in class org.apache.flink.runtime.instance.SlotPool |
From |
To |
|
Change Return Type int to CompletableFuture<Integer> in method public doStuff() : CompletableFuture<Integer> in class org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest.ExceptionalEndpoint |
From |
To |
|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public requestSlot(slotId SlotID, jobId JobID, allocationId AllocationID, targetAddress String, rmLeaderId UUID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Change Return Type Collection<JobID> to CompletableFuture<Collection<JobID>> in method public listJobs(timeout Time) : CompletableFuture<Collection<JobID>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Return Type C to RpcServer in method public startServer(rpcEndpoint S) : RpcServer in class org.apache.flink.runtime.rpc.TestingSerialRpcService |
From |
To |
|
Change Return Type KvStateLocation to CompletableFuture<KvStateLocation> in method public lookupKvStateLocation(registrationName String) : CompletableFuture<KvStateLocation> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Return Type CompletableFuture<Iterable<SlotOffer>> to CompletableFuture<Collection<SlotOffer>> in method public offerSlots(taskManagerId ResourceID, slots Iterable<SlotOffer>, leaderId UUID, timeout Time) : CompletableFuture<Collection<SlotOffer>> in class org.apache.flink.runtime.jobmaster.JobMasterGateway |
From |
To |
|
Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method public scheduleOrUpdateConsumers(leaderSessionID UUID, partitionID ResultPartitionID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |