|
Change Parameter Type requestJobFunction : Function<JobID,CompletableFuture<? extends AccessExecutionGraph>> to requestJobFunction : Function<JobID,CompletableFuture<ArchivedExecutionGraph>> in method private CountingRestfulGateway(expectedJobId JobID, requestJobFunction Function<JobID,CompletableFuture<ArchivedExecutionGraph>>) in class org.apache.flink.runtime.rest.handler.legacy.ExecutionGraphCacheTest.CountingRestfulGateway |
From |
To |
|
Change Parameter Type requestJobFunction : Function<JobID,CompletableFuture<? extends AccessExecutionGraph>> to requestJobFunction : Function<JobID,CompletableFuture<ArchivedExecutionGraph>> in method public setRequestJobFunction(requestJobFunction Function<JobID,CompletableFuture<ArchivedExecutionGraph>>) : Builder in class org.apache.flink.runtime.webmonitor.TestingRestfulGateway.Builder |
From |
To |
|
Change Parameter Type requestJobFunction : Function<JobID,CompletableFuture<? extends AccessExecutionGraph>> to requestJobFunction : Function<JobID,CompletableFuture<ArchivedExecutionGraph>> 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>>, requestMetricQueryServicePathsSupplier Supplier<CompletableFuture<Collection<String>>>, requestTaskManagerMetricQueryServicePathsSupplier 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 |
|
Change Parameter Type requestJobFunction : Function<JobID,CompletableFuture<? extends AccessExecutionGraph>> to requestJobFunction : Function<JobID,CompletableFuture<ArchivedExecutionGraph>> in method public setRequestJobFunction(requestJobFunction Function<JobID,CompletableFuture<ArchivedExecutionGraph>>) : TestingRestfulGateway.Builder in class org.apache.flink.runtime.webmonitor.TestingDispatcherGateway.Builder |
From |
To |
|
Change Parameter Type requestJobFunction : Function<JobID,CompletableFuture<? extends AccessExecutionGraph>> to requestJobFunction : Function<JobID,CompletableFuture<ArchivedExecutionGraph>> 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>>, requestMetricQueryServicePathsSupplier Supplier<CompletableFuture<Collection<String>>>, requestTaskManagerMetricQueryServicePathsSupplier 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 |
|
Change Parameter Type accessExecutionGraphs : CompletableFuture<? extends AccessExecutionGraph>... to accessExecutionGraphs : CompletableFuture<ArchivedExecutionGraph>... in method private createCountingRestfulGateway(jobId JobID, accessExecutionGraphs CompletableFuture<ArchivedExecutionGraph>...) : CountingRestfulGateway in class org.apache.flink.runtime.rest.handler.legacy.ExecutionGraphCacheTest |
From |
To |