a4865cd67239c938e0075bcc2b112b944cc3c249
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public testReleasingIdleSlotFailed() : void renamed to public testDiscardIdleSlotIfReleasingFailed() : void in class org.apache.flink.runtime.jobmaster.slotpool.SlotPoolTest | From | To | |
| Change Parameter Type | 3 | ||
| Change Parameter Type heartbeatJobManagerConsumer : Consumer<ResourceID> to heartbeatJobManagerConsumer : BiConsumer<ResourceID,AllocatedSlotReport> in method public setHeartbeatJobManagerConsumer(heartbeatJobManagerConsumer BiConsumer<ResourceID,AllocatedSlotReport>) : TestingTaskExecutorGatewayBuilder in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGatewayBuilder | From | To | |
| Change Parameter Type heartbeatJobManagerConsumer : Consumer<ResourceID> to heartbeatJobManagerConsumer : BiConsumer<ResourceID,AllocatedSlotReport> in method package TestingTaskExecutorGateway(address String, hostname String, heartbeatJobManagerConsumer BiConsumer<ResourceID,AllocatedSlotReport>, disconnectJobManagerConsumer BiConsumer<JobID,Throwable>, submitTaskConsumer BiFunction<TaskDeploymentDescriptor,JobMasterId,CompletableFuture<Acknowledge>>, requestSlotFunction Function<Tuple5<SlotID,JobID,AllocationID,String,ResourceManagerId>,CompletableFuture<Acknowledge>>, freeSlotFunction BiFunction<AllocationID,Throwable,CompletableFuture<Acknowledge>>, heartbeatResourceManagerConsumer Consumer<ResourceID>, disconnectResourceManagerConsumer Consumer<Exception>, cancelTaskFunction Function<ExecutionAttemptID,CompletableFuture<Acknowledge>>, canBeReleasedSupplier Supplier<Boolean>) in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGateway | From | To | |
| Change Parameter Type heartbeatConsumerFunction : BiFunction<JobMasterGateway,ResourceID,Consumer<ResourceID>> to heartbeatConsumerFunction : BiFunction<JobMasterGateway,ResourceID,BiConsumer<ResourceID,AllocatedSlotReport>> in method private runJobFailureWhenTaskExecutorTerminatesTest(heartbeatServices HeartbeatServices, jobReachedRunningState BiConsumer<LocalTaskManagerLocation,JobMasterGateway>, heartbeatConsumerFunction BiFunction<JobMasterGateway,ResourceID,BiConsumer<ResourceID,AllocatedSlotReport>>) : void in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To | |
| Change Return Type | 1 | ||
| Change Return Type CompletableFuture<Void> to CompletableFuture<AllocatedSlotReport> in method public retrievePayload(resourceID ResourceID) : CompletableFuture<AllocatedSlotReport> in class org.apache.flink.runtime.jobmaster.JobMaster.TaskManagerHeartbeatListener | From | To | |
| Change Attribute Type | 5 | ||
| Change Attribute Type NOOP_HEARTBEAT_JOBMANAGER_CONSUMER : Consumer<ResourceID> to NOOP_HEARTBEAT_JOBMANAGER_CONSUMER : BiConsumer<ResourceID,AllocatedSlotReport> in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGatewayBuilder | From | To | |
| Change Attribute Type heartbeatJobManagerConsumer : Consumer<ResourceID> to heartbeatJobManagerConsumer : BiConsumer<ResourceID,AllocatedSlotReport> in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGatewayBuilder | From | To | |
| Change Attribute Type taskManagerHeartbeatManager : HeartbeatManager<AccumulatorReport,Void> to taskManagerHeartbeatManager : HeartbeatManager<AccumulatorReport,AllocatedSlotReport> in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Change Attribute Type jobManagerHeartbeatManager : HeartbeatManager<Void,AccumulatorReport> to jobManagerHeartbeatManager : HeartbeatManager<AllocatedSlotReport,AccumulatorReport> in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Change Attribute Type heartbeatJobManagerConsumer : Consumer<ResourceID> to heartbeatJobManagerConsumer : BiConsumer<ResourceID,AllocatedSlotReport> in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGateway | From | To |