d4ba83e3baf31e041514e7340d4564ca0bee882a
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 7
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 4 | ||
| Change Return Type Acknowledge to CompletableFuture<Acknowledge> in method private suspendExecution(cause Exception) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Change Return Type void to CompletableFuture<Acknowledge> in method public suspend() : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPoolGateway | From | To | |
| Change Return Type void to CompletableFuture<Void> in method private verifyJobSchedulingStatusAndStartJobManager(leaderSessionId UUID) : CompletableFuture<Void> in class org.apache.flink.runtime.jobmaster.JobManagerRunner | From | To | |
| Change Return Type void to CompletableFuture<Acknowledge> in method public suspend() : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute jobMasterFactory : JobMasterServiceFactory to defaultJobMasterServiceFactory : JobMasterServiceFactory in class org.apache.flink.runtime.jobmaster.JobManagerRunnerTest | From | To | |
| Extract Method | 6 | ||
| Extract Method private startJobMaster(leaderSessionId UUID) : CompletionStage<Void> extracted from private verifyJobSchedulingStatusAndStartJobManager(leaderSessionId UUID) : void in class org.apache.flink.runtime.jobmaster.JobManagerRunner | From | To | |
| Extract Method private jobAlreadyDone() : CompletionStage<Void> extracted from private verifyJobSchedulingStatusAndStartJobManager(leaderSessionId UUID) : void in class org.apache.flink.runtime.jobmaster.JobManagerRunner | From | To | |
| Extract Method private handleException(leadershipOperation CompletableFuture<Void>, message String) : void extracted from public revokeLeadership() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunner | From | To | |
| Extract Method private getJobSchedulingStatus() : CompletableFuture<JobSchedulingStatus> extracted from private verifyJobSchedulingStatusAndStartJobManager(leaderSessionId UUID) : void in class org.apache.flink.runtime.jobmaster.JobManagerRunner | From | To | |
| Extract Method private createJobManagerRunner(jobMasterServiceFactory JobMasterServiceFactory, libraryCacheManager LibraryCacheManager) : JobManagerRunner extracted from private createJobManagerRunner(libraryCacheManager LibraryCacheManager) : JobManagerRunner in class org.apache.flink.runtime.jobmaster.JobManagerRunnerTest | From | To | |
| Extract Method private revokeJobMasterLeadership() : CompletableFuture<Void> extracted from public revokeLeadership() : void in class org.apache.flink.runtime.jobmaster.JobManagerRunner | From | To |