cc190a6457cdf6186ea8e449f7b38be04761af8b
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable t : Throwable to ie : Exception in method private persistAndRunJob(jobGraph JobGraph) : void in class org.apache.flink.runtime.dispatcher.Dispatcher | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type t : Throwable to ie : Exception in method private persistAndRunJob(jobGraph JobGraph) : void in class org.apache.flink.runtime.dispatcher.Dispatcher | From | To | |
| Extract Method | 8 | ||
| Extract Method private electDispatcher() : void extracted from public testFatalErrorAfterJobIdRecoveryFailure() : void in class org.apache.flink.runtime.dispatcher.DispatcherTest | From | To | |
| Extract Method private jobMasterFailed(jobId JobID, cause Throwable) : void extracted from public submitJob(jobGraph JobGraph, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher | From | To | |
| Extract Method private runJob(jobGraph JobGraph) : void extracted from public submitJob(jobGraph JobGraph, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher | From | To | |
| Extract Method private createJobManagerRunner(jobGraph JobGraph) : JobManagerRunner extracted from public submitJob(jobGraph JobGraph, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher | From | To | |
| Extract Method private electDispatcher() : void extracted from public testFatalErrorAfterJobRecoveryFailure() : void in class org.apache.flink.runtime.dispatcher.DispatcherTest | From | To | |
| Extract Method private electDispatcher() : void extracted from public testLeaderElection() : void in class org.apache.flink.runtime.dispatcher.DispatcherTest | From | To | |
| Extract Method private persistAndRunJob(jobGraph JobGraph) : void extracted from public submitJob(jobGraph JobGraph, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher | From | To | |
| Extract Method private recoverJob(jobId JobID) : void extracted from package recoverJobs() : void in class org.apache.flink.runtime.dispatcher.Dispatcher | From | To |