89cfeaa882f9e68df2bd215563622b48c29a9ec9
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Variable | 3 | ||
Rename Variable notifiedTaskManagerInfos : List<Tuple2<JobID,AllocationID>> to allocationFailures : Queue<Tuple2<JobID,AllocationID>> in method public testNotifyFailedAllocationWhenTaskManagerTerminated() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest | From | To | |
Rename Variable tm1SlotStatusList : Set<SlotStatus> to slotStatusSet : Set<SlotStatus> in method private createSlotReport(taskExecutorResourceId ResourceID, numberSlots int) : SlotReport in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest | From | To | |
Rename Variable tm2SlotStatusList : Set<SlotStatus> to failedAllocations : Set<AllocationID> in method public testNotifyFailedAllocationWhenTaskManagerTerminated() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest | From | To | |
Parameterize Variable | 1 | ||
Parameterize Variable taskExecutorResourceId1 : ResourceID to taskExecutorResourceId : ResourceID in method private createSlotReport(taskExecutorResourceId ResourceID, numberSlots int) : SlotReport in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest | From | To | |
Change Variable Type | 2 | ||
Change Variable Type notifiedTaskManagerInfos : List<Tuple2<JobID,AllocationID>> to allocationFailures : Queue<Tuple2<JobID,AllocationID>> in method public testNotifyFailedAllocationWhenTaskManagerTerminated() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest | From | To | |
Change Variable Type tm2SlotStatusList : Set<SlotStatus> to failedAllocations : Set<AllocationID> in method public testNotifyFailedAllocationWhenTaskManagerTerminated() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest | From | To | |
Extract Method | 3 | ||
Extract Method private createSlotReport(taskExecutorResourceId ResourceID, numberSlots int) : SlotReport extracted from public testNotifyFailedAllocationWhenTaskManagerTerminated() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest | From | To | |
Extract Method private extractFailedAllocationsForJob(jobId2 JobID, job2AndJob3FailedAllocationInfo Map<JobID,List<Tuple2<JobID,AllocationID>>>) : Set<AllocationID> extracted from public testNotifyFailedAllocationWhenTaskManagerTerminated() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest | From | To | |
Extract Method private createSlotRequest(jobId1 JobID) : SlotRequest extracted from public testNotifyFailedAllocationWhenTaskManagerTerminated() : void in class org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerTest | From | To |