cbed19c45f83e739c316fd011ce5334ed44712f2
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 12
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Variable | 1 | ||
Rename Variable taskManagerAddress : String to taskExecutorGateway : TaskExecutorGateway in method public requestTaskManagerMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> in class org.apache.flink.runtime.resourcemanager.ResourceManager | From | To | |
Replace Variable With Attribute | 2 | ||
Replace Variable With Attribute actorSystem : ActorSystem to metricQueryServiceActorSystem : ActorSystem in method protected initializeServices(configuration Configuration) : void in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint | From | To | |
Replace Variable With Attribute actorSystem : ActorSystem to metricQueryServiceActorSystem : ActorSystem in method public TaskManagerRunner(configuration Configuration, resourceId ResourceID) in class org.apache.flink.runtime.taskexecutor.TaskManagerRunner | From | To | |
Change Variable Type | 1 | ||
Change Variable Type taskManagerAddress : String to taskExecutorGateway : TaskExecutorGateway in method public requestTaskManagerMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> in class org.apache.flink.runtime.resourcemanager.ResourceManager | From | To | |
Extract Method | 3 | ||
Extract Method private bindWithPort(configuration Configuration, taskManagerHostname String, portRangeDefinition String) : RpcService extracted from public createRpcService(configuration Configuration, haServices HighAvailabilityServices) : RpcService in class org.apache.flink.runtime.taskexecutor.TaskManagerRunner | From | To | |
Extract Method public startActorSystem(configuration Configuration, listeningAddress String, portRangeDefinition String, logger Logger, executorMode ActorSystemExecutorMode) : ActorSystem extracted from public startActorSystem(configuration Configuration, listeningAddress String, portRangeDefinition String, logger Logger) : ActorSystem in class org.apache.flink.runtime.clusterframework.BootstrapTools | From | To | |
Extract Method public startActorSystem(configuration Configuration, listeningAddress String, listeningPort int, logger Logger, executorMode ActorSystemExecutorMode) : ActorSystem extracted from public startActorSystem(configuration Configuration, listeningAddress String, listeningPort int, logger Logger) : ActorSystem in class org.apache.flink.runtime.clusterframework.BootstrapTools | From | To |