21043356b29314977c2b638796327094b73e8a4a
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method private createHADispatcher(highAvailabilityServices TestingHighAvailabilityServices, fencingTokens BlockingQueue<DispatcherId>) : HATestingDispatcher renamed to private createDispatcher(highAvailabilityServices TestingHighAvailabilityServices, fencingTokens Queue<DispatcherId>) : HATestingDispatcher in class org.apache.flink.runtime.dispatcher.DispatcherHATest | From | To | |
| Pull Up Method | 1 | ||
| Pull Up Method package getNumberJobs(timeout Time) : CompletableFuture<Integer> from class org.apache.flink.runtime.dispatcher.DispatcherHATest.HATestingDispatcher to package getNumberJobs(timeout Time) : CompletableFuture<Integer> from class org.apache.flink.runtime.dispatcher.TestingDispatcher | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type fencingTokens : BlockingQueue<DispatcherId> to fencingTokens : Queue<DispatcherId> in method package HATestingDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, fencingTokens Queue<DispatcherId>) in class org.apache.flink.runtime.dispatcher.DispatcherHATest.HATestingDispatcher | From | To | |
| Change Parameter Type fencingTokens : BlockingQueue<DispatcherId> to fencingTokens : Queue<DispatcherId> in method private createDispatcher(highAvailabilityServices TestingHighAvailabilityServices, fencingTokens Queue<DispatcherId>) : HATestingDispatcher in class org.apache.flink.runtime.dispatcher.DispatcherHATest | From | To | |
| Extract Variable | 1 | ||
| Extract Variable fencingToken : DispatcherId in method protected setFencingToken(newFencingToken DispatcherId) : void from class org.apache.flink.runtime.dispatcher.DispatcherHATest.HATestingDispatcher | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type fencingTokens : BlockingQueue<DispatcherId> to fencingTokens : Queue<DispatcherId> in class org.apache.flink.runtime.dispatcher.DispatcherHATest.HATestingDispatcher | From | To |