7be3956d3e0ccd96d0f777f0fcf97080a1d63112
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 4
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 2 | ||
Change Parameter Type action : ConsumerWithException<JobGraph,?> to action : ThrowingConsumer<JobGraph,?> in method private waitForTerminatingJobManager(jobId JobID, jobGraph JobGraph, action ThrowingConsumer<JobGraph,?>) : CompletableFuture<Void> in class org.apache.flink.runtime.dispatcher.Dispatcher | From | To | |
Change Parameter Type discardCallback : ConsumerWithException<CompletedCheckpoint,Exception> to discardCallback : ThrowingConsumer<CompletedCheckpoint,Exception> in method private tryRemoveCompletedCheckpoint(completedCheckpoint CompletedCheckpoint, discardCallback ThrowingConsumer<CompletedCheckpoint,Exception>) : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore | From | To |