Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5430#discussion_r168148700 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/TestingRestfulGateway.java --- @@ -169,22 +192,26 @@ public static Builder newBuilder() { private String address = LOCALHOST; private String hostname = LOCALHOST; private String restAddress = LOCALHOST; + private Function<JobID, CompletableFuture<Acknowledge>> cancelJobFunction; + private Function<JobID, CompletableFuture<Acknowledge>> stopJobFunction; private Function<JobID, CompletableFuture<? extends AccessExecutionGraph>> requestJobFunction; private Function<JobID, CompletableFuture<JobStatus>> requestJobStatusFunction; private Supplier<CompletableFuture<MultipleJobsDetails>> requestMultipleJobDetailsSupplier; private Supplier<CompletableFuture<ClusterOverview>> requestClusterOverviewSupplier; private Supplier<CompletableFuture<Collection<String>>> requestMetricQueryServicePathsSupplier; private Supplier<CompletableFuture<Collection<Tuple2<ResourceID, String>>>> requestTaskManagerMetricQueryServicePathsSupplier; - private BiFunction<JobID, JobVertexID, CompletableFuture<OperatorBackPressureStatsResponse>> requestOeratorBackPressureStatsFunction; + private BiFunction<JobID, JobVertexID, CompletableFuture<OperatorBackPressureStatsResponse>> requestOperatorBackPressureStatsFunction; --- End diff -- nice
---