|
Rename Method public startMetricsActorSystem(configuration Configuration, hostname String, logger Logger) : ActorSystem renamed to public startMetricsRpcService(configuration Configuration, hostname String) : RpcService in class org.apache.flink.runtime.metrics.util.MetricUtils |
From |
To |
|
Rename Method public requestMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<String>> renamed to public requestMetricQueryServiceAddresses(timeout Time) : CompletableFuture<Collection<String>> in class org.apache.flink.runtime.webmonitor.TestingRestfulGateway |
From |
To |
|
Rename Method public requestTaskManagerMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> renamed to public requestTaskManagerMetricQueryServiceAddresses(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> in class org.apache.flink.runtime.webmonitor.RestfulGateway |
From |
To |
|
Rename Method public requestTaskManagerMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> renamed to public requestTaskManagerMetricQueryServiceAddresses(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> in class org.apache.flink.runtime.webmonitor.TestingRestfulGateway |
From |
To |
|
Rename Method public requestMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<String>> renamed to public requestMetricQueryServiceAddresses(timeout Time) : CompletableFuture<Collection<String>> in class org.apache.flink.runtime.webmonitor.RestfulGateway |
From |
To |
|
Rename Method public requestTaskManagerMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> renamed to public requestTaskManagerMetricQueryServiceAddresses(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> in class org.apache.flink.runtime.resourcemanager.utils.TestingResourceManagerGateway |
From |
To |
|
Rename Method public postStop() : void renamed to public onStop() : CompletableFuture<Void> in class org.apache.flink.runtime.metrics.dump.MetricQueryService |
From |
To |
|
Rename Method public requestTaskManagerMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> renamed to public requestTaskManagerMetricQueryServiceAddresses(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> in class org.apache.flink.runtime.resourcemanager.ResourceManagerGateway |
From |
To |
|
Rename Method public setRequestTaskManagerMetricQueryServicePathsSupplier(requestTaskManagerMetricQueryServicePathsSupplier Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>>) : Builder renamed to public setRequestTaskManagerMetricQueryServiceGatewaysSupplier(requestTaskManagerMetricQueryServiceGatewaysSupplier Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>>) : Builder in class org.apache.flink.runtime.webmonitor.TestingRestfulGateway.Builder |
From |
To |
|
Rename Method public requestTaskManagerMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> renamed to public requestTaskManagerMetricQueryServiceAddresses(timeout Time) : CompletableFuture<Collection<Tuple2<ResourceID,String>>> in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Rename Method public setRequestMetricQueryServicePathsSupplier(requestMetricQueryServicePathsSupplier Supplier<CompletableFuture<Collection<String>>>) : Builder renamed to public setRequestMetricQueryServiceGatewaysSupplier(requestMetricQueryServiceGatewaysSupplier Supplier<CompletableFuture<Collection<String>>>) : Builder in class org.apache.flink.runtime.webmonitor.TestingRestfulGateway.Builder |
From |
To |
|
Rename Method public requestMetricQueryServicePaths(timeout Time) : CompletableFuture<Collection<String>> renamed to public requestMetricQueryServiceAddresses(timeout Time) : CompletableFuture<Collection<String>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method package TestingDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServiceAddress String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.dispatcher.TestingDispatcher |
From |
To |
|
Rename Parameter metricServiceQueryPath : String to metricServiceQueryAddress : String in method public Dispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, submittedJobGraphStore SubmittedJobGraphStore, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricServiceQueryAddress String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method public TestingTaskExecutor(rpcService RpcService, taskManagerConfiguration TaskManagerConfiguration, haServices HighAvailabilityServices, taskExecutorServices TaskManagerServices, heartbeatServices HeartbeatServices, taskManagerMetricGroup TaskManagerMetricGroup, metricQueryServiceAddress String, blobCacheService BlobCacheService, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutor |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method package HATestingDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServiceAddress String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, fencingTokens Queue<DispatcherId>) in class org.apache.flink.runtime.dispatcher.DispatcherHATest.HATestingDispatcher |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method public createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServiceAddress String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.minicluster.SessionDispatcherWithUUIDFactory |
From |
To |
|
Rename Parameter requestTaskManagerMetricQueryServicePathsSupplier : Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>> to requestTaskManagerMetricQueryServiceGatewaysSupplier : Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>> in method public setRequestTaskManagerMetricQueryServiceGatewaysSupplier(requestTaskManagerMetricQueryServiceGatewaysSupplier Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>>) : Builder in class org.apache.flink.runtime.webmonitor.TestingRestfulGateway.Builder |
From |
To |
|
Rename Parameter metricQueryServiceRetriever : MetricQueryServiceRetriever to metricQueryServiceGatewayRetriever : MetricQueryServiceRetriever in method public fromConfiguration(configuration Configuration, metricQueryServiceGatewayRetriever MetricQueryServiceRetriever, dispatcherGatewayRetriever GatewayRetriever<T>, executor ExecutorService) : MetricFetcherImpl<T> in class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |
|
Rename Parameter queryServicePath : String to rpcServiceAddress : String in method public retrieveService(rpcServiceAddress String) : CompletableFuture<MetricQueryServiceGateway> in class org.apache.flink.runtime.webmonitor.retriever.MetricQueryServiceRetriever |
From |
To |
|
Rename Parameter requestMetricQueryServicePathsSupplier : Supplier<CompletableFuture<Collection<String>>> to requestMetricQueryServiceGatewaysSupplier : Supplier<CompletableFuture<Collection<String>>> in method public setRequestMetricQueryServiceGatewaysSupplier(requestMetricQueryServiceGatewaysSupplier Supplier<CompletableFuture<Collection<String>>>) : Builder in class org.apache.flink.runtime.webmonitor.TestingRestfulGateway.Builder |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method public createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServiceAddress String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) : T in class org.apache.flink.runtime.dispatcher.DispatcherFactory |
From |
To |
|
Rename Parameter requestMetricQueryServicePathsSupplier : Supplier<CompletableFuture<Collection<String>>> to requestMetricQueryServiceAddressesSupplier : Supplier<CompletableFuture<Collection<String>>> in method public TestingDispatcherGateway(address String, hostname String, cancelJobFunction Function<JobID,CompletableFuture<Acknowledge>>, stopJobFunction Function<JobID,CompletableFuture<Acknowledge>>, requestJobFunction Function<JobID,CompletableFuture<ArchivedExecutionGraph>>, requestJobResultFunction Function<JobID,CompletableFuture<JobResult>>, requestJobStatusFunction Function<JobID,CompletableFuture<JobStatus>>, requestMultipleJobDetailsSupplier Supplier<CompletableFuture<MultipleJobsDetails>>, requestClusterOverviewSupplier Supplier<CompletableFuture<ClusterOverview>>, requestMetricQueryServiceAddressesSupplier Supplier<CompletableFuture<Collection<String>>>, requestTaskManagerMetricQueryServiceGatewaysSupplier Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>>, requestOperatorBackPressureStatsFunction BiFunction<JobID,JobVertexID,CompletableFuture<OperatorBackPressureStatsResponse>>, triggerSavepointFunction BiFunction<JobID,String,CompletableFuture<String>>, submitFunction Function<JobGraph,CompletableFuture<Acknowledge>>, listFunction Supplier<CompletableFuture<Collection<JobID>>>, blobServerPort int, fencingToken DispatcherId, requestArchivedJobFunction Function<JobID,CompletableFuture<ArchivedExecutionGraph>>) in class org.apache.flink.runtime.webmonitor.TestingDispatcherGateway |
From |
To |
|
Rename Parameter requestMetricQueryServicePathsSupplier : Supplier<CompletableFuture<Collection<String>>> to requestMetricQueryServiceAddressesSupplier : Supplier<CompletableFuture<Collection<String>>> in method public TestingRestfulGateway(address String, hostname String, cancelJobFunction Function<JobID,CompletableFuture<Acknowledge>>, stopJobFunction Function<JobID,CompletableFuture<Acknowledge>>, requestJobFunction Function<JobID,CompletableFuture<ArchivedExecutionGraph>>, requestJobResultFunction Function<JobID,CompletableFuture<JobResult>>, requestJobStatusFunction Function<JobID,CompletableFuture<JobStatus>>, requestMultipleJobDetailsSupplier Supplier<CompletableFuture<MultipleJobsDetails>>, requestClusterOverviewSupplier Supplier<CompletableFuture<ClusterOverview>>, requestMetricQueryServiceAddressesSupplier Supplier<CompletableFuture<Collection<String>>>, requestTaskManagerMetricQueryServiceAddressesSupplier Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>>, requestOperatorBackPressureStatsFunction BiFunction<JobID,JobVertexID,CompletableFuture<OperatorBackPressureStatsResponse>>, triggerSavepointFunction BiFunction<JobID,String,CompletableFuture<String>>) in class org.apache.flink.runtime.webmonitor.TestingRestfulGateway |
From |
To |
|
Rename Parameter actorSystem : ActorSystem to rpcService : RpcService in method public startQueryService(rpcService RpcService, resourceID ResourceID) : void in class org.apache.flink.runtime.metrics.MetricRegistryImpl |
From |
To |
|
Rename Parameter requestMetricQueryServicePathsCounter : AtomicInteger to requestMetricQueryServiceGatewaysCounter : AtomicInteger in method private createRestfulGateway(requestMetricQueryServiceGatewaysCounter AtomicInteger) : RestfulGateway in class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherTest |
From |
To |
|
Rename Parameter requestTaskManagerMetricQueryServicePathsSupplier : Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>> to requestTaskManagerMetricQueryServiceAddressesSupplier : Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>> in method public TestingRestfulGateway(address String, hostname String, cancelJobFunction Function<JobID,CompletableFuture<Acknowledge>>, stopJobFunction Function<JobID,CompletableFuture<Acknowledge>>, requestJobFunction Function<JobID,CompletableFuture<ArchivedExecutionGraph>>, requestJobResultFunction Function<JobID,CompletableFuture<JobResult>>, requestJobStatusFunction Function<JobID,CompletableFuture<JobStatus>>, requestMultipleJobDetailsSupplier Supplier<CompletableFuture<MultipleJobsDetails>>, requestClusterOverviewSupplier Supplier<CompletableFuture<ClusterOverview>>, requestMetricQueryServiceAddressesSupplier Supplier<CompletableFuture<Collection<String>>>, requestTaskManagerMetricQueryServiceAddressesSupplier Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>>, requestOperatorBackPressureStatsFunction BiFunction<JobID,JobVertexID,CompletableFuture<OperatorBackPressureStatsResponse>>, triggerSavepointFunction BiFunction<JobID,String,CompletableFuture<String>>) in class org.apache.flink.runtime.webmonitor.TestingRestfulGateway |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method public createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServiceAddress String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) : MiniDispatcher in class org.apache.flink.runtime.dispatcher.JobDispatcherFactory |
From |
To |
|
Rename Parameter queryServicePath : String to queryServiceAddress : String in method private retrieveAndQueryMetrics(queryServiceAddress String) : void in class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method public TaskExecutor(rpcService RpcService, taskManagerConfiguration TaskManagerConfiguration, haServices HighAvailabilityServices, taskExecutorServices TaskManagerServices, heartbeatServices HeartbeatServices, taskManagerMetricGroup TaskManagerMetricGroup, metricQueryServiceAddress String, blobCacheService BlobCacheService, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.taskexecutor.TaskExecutor |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method public StandaloneDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServiceAddress String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Rename Parameter requestTaskManagerMetricQueryServicePathsSupplier : Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>> to requestTaskManagerMetricQueryServiceGatewaysSupplier : Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>> in method public TestingDispatcherGateway(address String, hostname String, cancelJobFunction Function<JobID,CompletableFuture<Acknowledge>>, stopJobFunction Function<JobID,CompletableFuture<Acknowledge>>, requestJobFunction Function<JobID,CompletableFuture<ArchivedExecutionGraph>>, requestJobResultFunction Function<JobID,CompletableFuture<JobResult>>, requestJobStatusFunction Function<JobID,CompletableFuture<JobStatus>>, requestMultipleJobDetailsSupplier Supplier<CompletableFuture<MultipleJobsDetails>>, requestClusterOverviewSupplier Supplier<CompletableFuture<ClusterOverview>>, requestMetricQueryServiceAddressesSupplier Supplier<CompletableFuture<Collection<String>>>, requestTaskManagerMetricQueryServiceGatewaysSupplier Supplier<CompletableFuture<Collection<Tuple2<ResourceID,String>>>>, requestOperatorBackPressureStatsFunction BiFunction<JobID,JobVertexID,CompletableFuture<OperatorBackPressureStatsResponse>>, triggerSavepointFunction BiFunction<JobID,String,CompletableFuture<String>>, submitFunction Function<JobGraph,CompletableFuture<Acknowledge>>, listFunction Supplier<CompletableFuture<Collection<JobID>>>, blobServerPort int, fencingToken DispatcherId, requestArchivedJobFunction Function<JobID,CompletableFuture<ArchivedExecutionGraph>>) in class org.apache.flink.runtime.webmonitor.TestingDispatcherGateway |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method public MiniDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServiceAddress String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist, jobGraph JobGraph, executionMode JobClusterEntrypoint.ExecutionMode) in class org.apache.flink.runtime.dispatcher.MiniDispatcher |
From |
To |
|
Rename Parameter metricQueryServicePath : String to metricQueryServiceAddress : String in method public createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServiceAddress String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.dispatcher.SessionDispatcherFactory |
From |
To |