95d4c0170339585cb4876c4bafc1c2a42c44be3c
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 1 | ||
| Change Return Type CompletableFuture<Void> to CompletableFuture<AccumulatorReport> in method public retrievePayload(resourceID ResourceID) : CompletableFuture<AccumulatorReport> in class org.apache.flink.runtime.taskexecutor.TaskExecutor.JobManagerHeartbeatListener | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type payload : Void to payload : AccumulatorReport in method private establishJobManagerConnection(jobId JobID, jobMasterGateway JobMasterGateway, registrationSuccess JMTMRegistrationSuccess) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type taskManagerHeartbeatManager : HeartbeatManager<Void,Void> to taskManagerHeartbeatManager : HeartbeatManager<AccumulatorReport,Void> in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Change Attribute Type jobManagerHeartbeatManager : HeartbeatManager<Void,Void> to jobManagerHeartbeatManager : HeartbeatManager<Void,AccumulatorReport> in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To |