8d1545febfb7e1c02a9f5a948efc8b8eb4247742
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute newExecutionGraph : ExecutionGraph to jobManagerJobMetricGroup : JobManagerJobMetricGroup in method private assignExecutionGraph(newExecutionGraph ExecutionGraph, newJobManagerJobMetricGroup JobManagerJobMetricGroup) : void in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type newExecutionGraph : ExecutionGraph to jobManagerJobMetricGroup : JobManagerJobMetricGroup in method private assignExecutionGraph(newExecutionGraph ExecutionGraph, newJobManagerJobMetricGroup JobManagerJobMetricGroup) : void in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Extract Method | 7 | ||
| Extract Method private startJobMasterServices() : void extracted from private startJobExecution(newJobMasterId JobMasterId) : Acknowledge in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Extract Method private assignExecutionGraph(newExecutionGraph ExecutionGraph, newJobManagerJobMetricGroup JobManagerJobMetricGroup) : void extracted from public rescaleOperators(operators Collection<JobVertexID>, newParallelism int, rescalingBehaviour RescalingBehaviour, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Extract Method private suspendExecutionGraph(cause Exception) : void extracted from private suspendExecution(cause Exception) : Acknowledge in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Extract Method private suspendAndClearExecutionGraphFields(cause Exception) : void extracted from private suspendExecution(cause Exception) : Acknowledge in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Extract Method private createAndRestoreExecutionGraph(currentJobManagerJobMetricGroup JobManagerJobMetricGroup) : ExecutionGraph extracted from public JobMaster(rpcService RpcService, jobMasterConfiguration JobMasterConfiguration, resourceId ResourceID, jobGraph JobGraph, highAvailabilityService HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobMetricGroupFactory JobManagerJobMetricGroupFactory, jobCompletionActions OnCompletionActions, errorHandler FatalErrorHandler, userCodeLoader ClassLoader, restAddress String, metricQueryServicePath String) in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Extract Method private createExecutionGraph(currentJobManagerJobMetricGroup JobManagerJobMetricGroup) : ExecutionGraph extracted from public JobMaster(rpcService RpcService, jobMasterConfiguration JobMasterConfiguration, resourceId ResourceID, jobGraph JobGraph, highAvailabilityService HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobMetricGroupFactory JobManagerJobMetricGroupFactory, jobCompletionActions OnCompletionActions, errorHandler FatalErrorHandler, userCodeLoader ClassLoader, restAddress String, metricQueryServicePath String) in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Extract Method private setNewFencingToken(newJobMasterId JobMasterId) : void extracted from private startJobExecution(newJobMasterId JobMasterId) : Acknowledge in class org.apache.flink.runtime.jobmaster.JobMaster | From | To |