|
Change Variable Type savepoint1 : Future<CompletedCheckpoint> to savepoint1 : CompletableFuture<CompletedCheckpoint> in method public testMinDelayBetweenSavepoints() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type savepointFuture1 : Future<CompletedCheckpoint> to savepointFuture1 : CompletableFuture<CompletedCheckpoint> in method public testSavepointsAreNotSubsumed() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type savepointFuture : Future<CompletedCheckpoint> to savepointFuture : CompletableFuture<CompletedCheckpoint> in method public testSavepointsAreNotAddedToCompletedCheckpointStore() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type savepointFuture2 : Future<CompletedCheckpoint> to savepointFuture2 : CompletableFuture<CompletedCheckpoint> in method public testSavepointsAreNotSubsumed() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type result : Future<CompletedCheckpoint> to result : CompletableFuture<CompletedCheckpoint> in method public triggerSavepoint(timestamp long, targetDirectory String) : CompletableFuture<CompletedCheckpoint> in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Change Variable Type savepointFuture : Future<CompletedCheckpoint> to savepointFuture : CompletableFuture<CompletedCheckpoint> in method public testConcurrentSavepoints() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type future : Future<CompletedCheckpoint> to future : CompletableFuture<CompletedCheckpoint> in method public testCompletionFuture() : void in class org.apache.flink.runtime.checkpoint.PendingCheckpointTest |
From |
To |
|
Change Variable Type savepointFutures : List<Future<CompletedCheckpoint>> to savepointFutures : List<CompletableFuture<CompletedCheckpoint>> in method public testConcurrentSavepoints() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type savepoint0 : Future<CompletedCheckpoint> to savepoint0 : CompletableFuture<CompletedCheckpoint> in method public testMinDelayBetweenSavepoints() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type savepointFuture : Future<CompletedCheckpoint> to savepointFuture : CompletableFuture<CompletedCheckpoint> in method public testTriggerAndConfirmSimpleSavepoint() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |