1321c17047daed756ce4216814b8708162a57e83
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 34
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public testTimeoutForSlotAllocation() : void renamed to public testEagerSchedulingWithSlotTimeout() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphSchedulingTest | From | To | |
| Rename Variable | 1 | ||
| Rename Variable allAllocationsComplete : ConjunctFuture<Collection<Execution>> to allAllocationsFuture : ConjunctFuture<Collection<Execution>> in method private scheduleEager(slotProvider SlotProvider, timeout Time) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Rename Attribute | 5 | ||
| Rename Attribute rpcCallTimeout : Time to rpcTimeout : Time in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Rename Attribute timeout : Time to rpcTimeout : Time in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Rename Attribute scheduleAllocationTimeout : Time to allocationTimeout : Time in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Rename Attribute resourceManagerAllocationTimeout : Time to slotRequestTimeout : Time in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Rename Attribute timeout : Time to rpcTimeout : Time in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testSlotReleasedWhenScheduledImmediately() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexSchedulingTest | From | To | |
| Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testScheduleToDeploying() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexSchedulingTest | From | To | |
| Change Variable Type future : CompletableFuture<SimpleSlot> to future : CompletableFuture<LogicalSlot> in method public testSlotReleasedWhenScheduledQueued() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexSchedulingTest | From | To | |
| Extract Variable | 3 | ||
| Extract Variable timeout : Time in method private createExecutionGraphAndEnableCheckpointing(counter CheckpointIDCounter, store CompletedCheckpointStore) : ExecutionGraph from class org.apache.flink.runtime.checkpoint.ExecutionGraphCheckpointCoordinatorTest | From | To | |
| Extract Variable executionGraph : ExecutionGraph in method public scheduleForExecution() : boolean from class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Extract Variable executionGraph : ExecutionGraph in method package scheduleOrUpdateConsumers(allConsumers List<List<ExecutionEdge>>) : void from class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter resourceManagerAllocationTimeout : Time to rpcTimeout : Time in method public TestingSlotPool(rpcService RpcService, jobId JobID, clock Clock, slotRequestTimeout Time, rpcTimeout Time, idleSlotTimeout Time) in class org.apache.flink.runtime.jobmaster.slotpool.SlotPoolRpcTest.TestingSlotPool | From | To | |
| Rename Parameter timeout : Time to rpcTimeout : Time in method public Execution(executor Executor, vertex ExecutionVertex, attemptNumber int, globalModVersion long, startTimestamp long, rpcTimeout Time) in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Rename Parameter resourceManagerAllocationTimeout : Time to rpcTimeout : Time in method public SlotPool(rpcService RpcService, jobId JobID, clock Clock, slotRequestTimeout Time, rpcTimeout Time, idleSlotTimeout Time) in class org.apache.flink.runtime.jobmaster.slotpool.SlotPool | From | To |