|
Change Parameter Type executor : Executor to scheduledExecutor : ScheduledExecutor in method public WebRuntimeMonitor(config Configuration, leaderRetrievalService LeaderRetrievalService, blobView BlobView, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, scheduledExecutor ScheduledExecutor) in class org.apache.flink.runtime.webmonitor.WebRuntimeMonitor |
From |
To |
|
Change Parameter Type executor : Executor to scheduledExecutor : ScheduledExecutor in method public startWebRuntimeMonitor(config Configuration, highAvailabilityServices HighAvailabilityServices, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, scheduledExecutor ScheduledExecutor) : WebMonitor in class org.apache.flink.runtime.webmonitor.WebMonitorUtils |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public SubtasksAllAccumulatorsHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.SubtasksAllAccumulatorsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphCache : ExecutionGraphCache in method public AbstractExecutionGraphRequestHandler(executionGraphCache ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.AbstractExecutionGraphRequestHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public JobAccumulatorsHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.JobAccumulatorsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public AbstractJobVertexRequestHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.AbstractJobVertexRequestHandler |
From |
To |
|
Change Parameter Type currentGraphs : ExecutionGraphHolder to currentGraphs : ExecutionGraphCache in method public TriggerHandler(currentGraphs ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers.TriggerHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public CheckpointStatsDetailsHandler(executionGraphHolder ExecutionGraphCache, executor Executor, cache CheckpointStatsCache) in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointStatsDetailsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public SubtaskExecutionAttemptAccumulatorsHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.SubtaskExecutionAttemptAccumulatorsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public JobDetailsHandler(executionGraphHolder ExecutionGraphCache, executor Executor, fetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.legacy.JobDetailsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public CheckpointConfigHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandler |
From |
To |
|
Change Parameter Type executor : Executor to scheduledExecutor : ScheduledExecutor in method public startWebMonitorIfConfigured(config Configuration, highAvailabilityServices HighAvailabilityServices, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, scheduledExecutor ScheduledExecutor, logger Logger) : WebMonitor in class org.apache.flink.runtime.clusterframework.BootstrapTools |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public SubtaskExecutionAttemptDetailsHandler(executionGraphHolder ExecutionGraphCache, executor Executor, fetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.legacy.SubtaskExecutionAttemptDetailsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public AbstractSubtaskAttemptRequestHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.AbstractSubtaskAttemptRequestHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public JobVertexBackPressureHandler(executionGraphHolder ExecutionGraphCache, executor Executor, backPressureStatsTracker BackPressureStatsTracker, refreshInterval int) in class org.apache.flink.runtime.rest.handler.legacy.JobVertexBackPressureHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public SubtasksTimesHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.SubtasksTimesHandler |
From |
To |
|
Change Parameter Type currentGraphs : ExecutionGraphHolder to currentGraphs : ExecutionGraphCache in method public JobCancellationWithSavepointHandlers(currentGraphs ExecutionGraphCache, executor Executor, defaultSavepointDirectory String) in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public JobVertexAccumulatorsHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.JobVertexAccumulatorsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public JobExceptionsHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.JobExceptionsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public CheckpointStatsHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointStatsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public CheckpointStatsDetailsSubtasksHandler(executionGraphHolder ExecutionGraphCache, executor Executor, cache CheckpointStatsCache) in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointStatsDetailsSubtasksHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public AbstractSubtaskRequestHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.AbstractSubtaskRequestHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphCache : ExecutionGraphCache in method public JobConfigHandler(executionGraphCache ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.JobConfigHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public JobVertexTaskManagersHandler(executionGraphHolder ExecutionGraphCache, executor Executor, fetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.legacy.JobVertexTaskManagersHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public JobPlanHandler(executionGraphHolder ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.JobPlanHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public JobVertexDetailsHandler(executionGraphHolder ExecutionGraphCache, executor Executor, fetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.legacy.JobVertexDetailsHandler |
From |
To |
|
Change Parameter Type executionGraphHolder : ExecutionGraphHolder to executionGraphHolder : ExecutionGraphCache in method public SubtaskCurrentAttemptDetailsHandler(executionGraphHolder ExecutionGraphCache, executor Executor, fetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.legacy.SubtaskCurrentAttemptDetailsHandler |
From |
To |
|
Change Parameter Type currentGraphs : ExecutionGraphHolder to currentGraphs : ExecutionGraphCache in method public JobCancellationWithSavepointHandlers(currentGraphs ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers |
From |
To |
|
Change Variable Type holder : ExecutionGraphHolder to holder : ExecutionGraphCache in method public testFailedCancellation() : void in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Change Variable Type currentGraphs : ExecutionGraphHolder to executionGraphCache : ExecutionGraphCache in method public WebRuntimeMonitor(config Configuration, leaderRetrievalService LeaderRetrievalService, blobView BlobView, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, scheduledExecutor ScheduledExecutor) in class org.apache.flink.runtime.webmonitor.WebRuntimeMonitor |
From |
To |
|
Change Variable Type holder : ExecutionGraphHolder to holder : ExecutionGraphCache in method public testAskTimeoutEqualsCheckpointTimeout() : void in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Change Variable Type graphFuture : CompletableFuture<Optional<AccessExecutionGraph>> to graphFuture : CompletableFuture<AccessExecutionGraph> in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : CompletableFuture<String> in class org.apache.flink.runtime.rest.handler.legacy.AbstractExecutionGraphRequestHandler |
From |
To |
|
Change Variable Type graphFuture : CompletableFuture<Optional<AccessExecutionGraph>> to graphFuture : CompletableFuture<AccessExecutionGraph> in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : CompletableFuture<FullHttpResponse> in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlers.TriggerHandler |
From |
To |
|
Change Variable Type holder : ExecutionGraphHolder to holder : ExecutionGraphCache in method public testTriggerNewRequest() : void in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Change Variable Type holder : ExecutionGraphHolder to holder : ExecutionGraphCache in method public testSavepointDirectoryConfiguration() : void in class org.apache.flink.runtime.rest.handler.legacy.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Rename Parameter executor : Executor to scheduledExecutor : ScheduledExecutor in method public startWebRuntimeMonitor(config Configuration, highAvailabilityServices HighAvailabilityServices, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, scheduledExecutor ScheduledExecutor) : WebMonitor in class org.apache.flink.runtime.webmonitor.WebMonitorUtils |
From |
To |
|
Rename Parameter executor : Executor to scheduledExecutor : ScheduledExecutor in method public WebRuntimeMonitor(config Configuration, leaderRetrievalService LeaderRetrievalService, blobView BlobView, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, scheduledExecutor ScheduledExecutor) in class org.apache.flink.runtime.webmonitor.WebRuntimeMonitor |
From |
To |
|
Rename Parameter executionGraphHolder : ExecutionGraphHolder to executionGraphCache : ExecutionGraphCache in method public AbstractExecutionGraphRequestHandler(executionGraphCache ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.AbstractExecutionGraphRequestHandler |
From |
To |
|
Rename Parameter executionGraphHolder : ExecutionGraphHolder to executionGraphCache : ExecutionGraphCache in method public JobConfigHandler(executionGraphCache ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.legacy.JobConfigHandler |
From |
To |
|
Rename Parameter executor : Executor to scheduledExecutor : ScheduledExecutor in method public startWebMonitorIfConfigured(config Configuration, highAvailabilityServices HighAvailabilityServices, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, scheduledExecutor ScheduledExecutor, logger Logger) : WebMonitor in class org.apache.flink.runtime.clusterframework.BootstrapTools |
From |
To |