c2891c5d467ad4a4dccde733e519e1a7250eb990
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 12
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 6 | ||
Rename Method public getJobMasterLeaderRetriever(jobID JobID) : LeaderRetrievalService renamed to public getJobManagerLeaderRetriever(jobID JobID) : LeaderRetrievalService in class org.apache.flink.runtime.highavailability.HighAvailabilityServices | From | To | |
Rename Method public getJobMasterLeaderRetriever(jobID JobID) : LeaderRetrievalService renamed to public getJobManagerLeaderRetriever(jobID JobID) : LeaderRetrievalService in class org.apache.flink.runtime.highavailability.NonHaServices | From | To | |
Rename Method public getJobMasterLeaderElectionService(jobID JobID) : LeaderElectionService renamed to public getJobManagerLeaderElectionService(jobID JobID) : LeaderElectionService in class org.apache.flink.runtime.highavailability.HighAvailabilityServices | From | To | |
Rename Method public getJobMasterLeaderRetriever(jobID JobID) : LeaderRetrievalService renamed to public getJobManagerLeaderRetriever(jobID JobID) : LeaderRetrievalService in class org.apache.flink.runtime.highavailability.TestingHighAvailabilityServices | From | To | |
Rename Method public getJobMasterLeaderElectionService(jobID JobID) : LeaderElectionService renamed to public getJobManagerLeaderElectionService(jobID JobID) : LeaderElectionService in class org.apache.flink.runtime.highavailability.NonHaServices | From | To | |
Rename Method public getJobMasterLeaderElectionService(jobID JobID) : LeaderElectionService renamed to public getJobManagerLeaderElectionService(jobID JobID) : LeaderElectionService in class org.apache.flink.runtime.highavailability.TestingHighAvailabilityServices | From | To | |
Change Return Type | 2 | ||
Change Return Type Acknowledge to boolean in method public updateTaskExecutionState(taskExecutionState TaskExecutionState) : boolean in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
Change Return Type Future<Acknowledge> to Future<Boolean> in method public updateTaskExecutionState(taskExecutionState TaskExecutionState) : Future<Boolean> in class org.apache.flink.runtime.jobmaster.JobMasterGateway | From | To | |
Rename Attribute | 1 | ||
Rename Attribute checkpointRecoveryFactory : CheckpointRecoveryFactory to submittedJobGraphStore : SubmittedJobGraphStore in class org.apache.flink.runtime.jobmaster.JobManagerRunner | From | To | |
Extract Method | 2 | ||
Extract Method public createLeaderElectionService(client CuratorFramework, configuration Configuration, pathSuffix String) : ZooKeeperLeaderElectionService extracted from public createLeaderElectionService(client CuratorFramework, configuration Configuration) : ZooKeeperLeaderElectionService in class org.apache.flink.runtime.util.ZooKeeperUtils | From | To | |
Extract Method public createLeaderRetrievalService(client CuratorFramework, configuration Configuration) : ZooKeeperLeaderRetrievalService extracted from public createLeaderRetrievalService(configuration Configuration) : ZooKeeperLeaderRetrievalService in class org.apache.flink.runtime.util.ZooKeeperUtils | From | To | |
Change Attribute Type | 1 | ||
Change Attribute Type checkpointRecoveryFactory : CheckpointRecoveryFactory to submittedJobGraphStore : SubmittedJobGraphStore in class org.apache.flink.runtime.jobmaster.JobManagerRunner | From | To |