|
Rename Variable jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public cancelJob(jobId JobID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable jobStatus : ArrayList<CompletableFuture<JobStatus>> to optionalJobInformation : ArrayList<CompletableFuture<Optional<T>>> in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable startingFuture : CompletableFuture<Acknowledge> to startFuture : CompletableFuture<Acknowledge> in method private verifyJobSchedulingStatusAndStartJobManager(leaderSessionId UUID) : void in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |
|
Rename Variable jobManagerRunnerEntry : Map.Entry<JobID,JobManagerRunner> to jobId : JobID in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable jobStatusFuture : CompletableFuture<JobStatus> to optionalRequest : CompletableFuture<Optional<T>> in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public requestJobStatus(jobId JobID, timeout Time) : CompletableFuture<JobStatus> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable jobStatus : ArrayList<CompletableFuture<JobStatus>> to optionalJobInformation : List<CompletableFuture<Optional<JobStatus>>> in method public requestClusterOverview(timeout Time) : CompletableFuture<ClusterOverview> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public requestOperatorBackPressureStats(jobId JobID, jobVertexId JobVertexID) : CompletableFuture<OperatorBackPressureStatsResponse> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable jobManagerRunner : JobManagerRunner to jobId : JobID in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable individualJobDetails : ArrayList<CompletableFuture<JobDetails>> to optionalJobInformation : ArrayList<CompletableFuture<Optional<T>>> in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public stopJob(jobId JobID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public rescaleJob(jobId JobID, newParallelism int, rescalingBehaviour RescalingBehaviour, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public requestJob(jobId JobID, timeout Time) : CompletableFuture<ArchivedExecutionGraph> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable individualJobDetails : ArrayList<CompletableFuture<JobDetails>> to individualOptionalJobDetails : List<CompletableFuture<Optional<JobDetails>>> in method public requestMultipleJobDetails(timeout Time) : CompletableFuture<MultipleJobsDetails> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Variable schedulingStatus : JobSchedulingStatus to jobSchedulingStatus : JobSchedulingStatus in method private verifyJobSchedulingStatusAndStartJobManager(leaderSessionId UUID) : void in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |
|
Change Variable Type jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public requestOperatorBackPressureStats(jobId JobID, jobVertexId JobVertexID) : CompletableFuture<OperatorBackPressureStatsResponse> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobManagerRunner : JobManagerRunner to jobId : JobID in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type individualJobDetails : ArrayList<CompletableFuture<JobDetails>> to optionalJobInformation : ArrayList<CompletableFuture<Optional<T>>> in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public stopJob(jobId JobID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public rescaleJob(jobId JobID, newParallelism int, rescalingBehaviour RescalingBehaviour, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public requestJob(jobId JobID, timeout Time) : CompletableFuture<ArchivedExecutionGraph> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type individualJobDetails : ArrayList<CompletableFuture<JobDetails>> to individualOptionalJobDetails : List<CompletableFuture<Optional<JobDetails>>> in method public requestMultipleJobDetails(timeout Time) : CompletableFuture<MultipleJobsDetails> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public cancelJob(jobId JobID, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobStatus : ArrayList<CompletableFuture<JobStatus>> to optionalJobInformation : ArrayList<CompletableFuture<Optional<T>>> in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobManagerRunnerEntry : Map.Entry<JobID,JobManagerRunner> to jobId : JobID in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobStatusFuture : CompletableFuture<JobStatus> to optionalRequest : CompletableFuture<Optional<T>> in method private queryJobMastersForInformation(queryFunction Function<JobMasterGateway,CompletableFuture<T>>) : List<CompletableFuture<Optional<T>>> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobManagerRunner : JobManagerRunner to jobMasterGatewayFuture : CompletableFuture<JobMasterGateway> in method public requestJobStatus(jobId JobID, timeout Time) : CompletableFuture<JobStatus> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Variable Type jobStatus : ArrayList<CompletableFuture<JobStatus>> to optionalJobInformation : List<CompletableFuture<Optional<JobStatus>>> in method public requestClusterOverview(timeout Time) : CompletableFuture<ClusterOverview> in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |