b08e257019a24f7c0fc8fa8817858fc39bc60795
Files Diff
- Added: 2
- Removed: 2
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 1 | ||
Rename Method private grantResourceManagerLeadership(leaderElectionService TestingLeaderElectionService) : UUID renamed to private grantLeadership(leaderElectionService TestingLeaderElectionService) : UUID in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest | From | To | |
Move Method | 3 | ||
Move Method public revokeLeadership() : void from class org.apache.flink.runtime.resourcemanager.ResourceManager.ResourceManagerLeaderContender to public revokeLeadership() : void from class org.apache.flink.runtime.resourcemanager.ResourceManager | From | To | |
Move Method public grantLeadership(leaderSessionID UUID) : void from class org.apache.flink.runtime.resourcemanager.ResourceManager.ResourceManagerLeaderContender to public grantLeadership(leaderSessionID UUID) : void from class org.apache.flink.runtime.resourcemanager.ResourceManager | From | To | |
Move Method public handleError(exception Exception) : void from class org.apache.flink.runtime.resourcemanager.ResourceManager.ResourceManagerLeaderContender to public handleError(exception Exception) : void from class org.apache.flink.runtime.resourcemanager.ResourceManager | From | To | |
Rename Variable | 2 | ||
Rename Variable leaderElectionService : TestingLeaderElectionService to rmLeaderElectionService : TestingLeaderElectionService in method public testRegisterTaskExecutorWithUnmatchedLeaderSessionId() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest | From | To | |
Rename Variable leaderElectionService : TestingLeaderElectionService to rmLeaderElectionService : TestingLeaderElectionService in method public testRegisterTaskExecutor() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest | From | To | |
Change Return Type | 2 | ||
Change Return Type SlotAssignment to SlotRequestReply in method public requestSlot(slotRequest SlotRequest) : SlotRequestReply in class org.apache.flink.runtime.resourcemanager.ResourceManager | From | To | |
Change Return Type Future<SlotAssignment> to Future<SlotRequestReply> in method public requestSlot(slotRequest SlotRequest) : Future<SlotRequestReply> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway | From | To | |
Rename Class | 1 | ||
Rename Class org.apache.flink.runtime.resourcemanager.ResourceManagerTest renamed to org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest | From | To | |
Rename Attribute | 1 | ||
Rename Attribute startedTaskExecutorGateways : Map<ResourceID,TaskExecutorRegistration> to taskExecutorGateways : Map<ResourceID,TaskExecutorRegistration> in class org.apache.flink.runtime.resourcemanager.ResourceManager | From | To | |
Extract Variable | 2 | ||
Extract Variable testingHaServices : TestingHighAvailabilityServices in method public testSlotsUnavailableRequest() : void from class org.apache.flink.runtime.resourcemanager.slotmanager.SlotProtocolTest | From | To | |
Extract Variable testingHaServices : TestingHighAvailabilityServices in method public testSlotAvailableRequest() : void from class org.apache.flink.runtime.resourcemanager.slotmanager.SlotProtocolTest | From | To | |
Change Attribute Type | 1 | ||
Change Attribute Type jobMasterGateways : Map<JobMasterGateway,InstanceID> to jobMasterGateways : Map<JobID,JobMasterGateway> in class org.apache.flink.runtime.resourcemanager.ResourceManager | From | To | |
Rename Parameter | 1 | ||
Rename Parameter leaderElectionService : TestingLeaderElectionService to rmLeaderElectionService : TestingLeaderElectionService in method private createAndStartResourceManager(rmLeaderElectionService TestingLeaderElectionService) : ResourceManager in class org.apache.flink.runtime.resourcemanager.ResourceManagerTaskExecutorTest | From | To |