This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5f4178bb782dafb4520b1459e51e417d641a03a0 Author: Chesnay Schepler <[email protected]> AuthorDate: Mon Apr 11 17:33:51 2022 +0200 [hotfix][tests] Allow retrieval of termination future for running jobs --- .../java/org/apache/flink/runtime/dispatcher/Dispatcher.java | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java index 51502441349..6d8897e3a65 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java @@ -1215,15 +1215,10 @@ public abstract class Dispatcher extends PermanentlyFencedRpcEndpoint<Dispatcher getMainThreadExecutor()); } + @VisibleForTesting CompletableFuture<Void> getJobTerminationFuture(JobID jobId) { - if (jobManagerRunnerRegistry.isRegistered(jobId)) { - return FutureUtils.completedExceptionally( - new DispatcherException( - String.format("Job with job id %s is still running.", jobId))); - } else { - return jobManagerRunnerTerminationFutures.getOrDefault( - jobId, CompletableFuture.completedFuture(null)); - } + return jobManagerRunnerTerminationFutures.getOrDefault( + jobId, CompletableFuture.completedFuture(null)); } private void registerDispatcherMetrics(MetricGroup jobManagerMetricGroup) {
