|
Change Return Type Future<ExecutionState> to CompletableFuture<ExecutionState> in method public requestPartitionProducerState(jobId JobID, resultId IntermediateDataSetID, partitionId ResultPartitionID) : CompletableFuture<ExecutionState> in class org.apache.flink.runtime.taskexecutor.rpc.RpcPartitionStateChecker |
From |
To |
|
Change Return Type Future<ExecutionState> to CompletableFuture<ExecutionState> in method public requestPartitionProducerState(jobId JobID, intermediateDataSetId IntermediateDataSetID, resultPartitionId ResultPartitionID) : CompletableFuture<ExecutionState> in class org.apache.flink.runtime.io.network.netty.PartitionProducerStateChecker |
From |
To |
|
Change Return Type Future<ExecutionState> to CompletableFuture<ExecutionState> in method public requestPartitionProducerState(jobId JobID, intermediateDataSetId IntermediateDataSetID, r ResultPartitionID) : CompletableFuture<ExecutionState> in class org.apache.flink.runtime.util.JvmExitOnFatalErrorTest.ProcessEntryPoint.NoOpPartitionProducerStateChecker |
From |
To |
|
Change Return Type Future<ExecutionState> to CompletableFuture<ExecutionState> in method public requestPartitionProducerState(jobId JobID, intermediateDataSetId IntermediateDataSetID, resultPartitionId ResultPartitionID) : CompletableFuture<ExecutionState> in class org.apache.flink.runtime.taskmanager.ActorGatewayPartitionProducerStateChecker |
From |
To |