From 2731723241327a1dace36b035b3ec25fb700174a Mon Sep 17 00:00:00 2001 From: Matthias Pohl Date: Tue, 26 Nov 2024 08:23:09 +0100 Subject: [PATCH] [hotfix][runtime] Removes unused FlinkException in signature --- .../runtime/jobmaster/JobMasterServiceLeadershipRunner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java index 875e4ca58b51d..a3bb244570442 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java @@ -330,7 +330,7 @@ private void jobAlreadyDone(UUID leaderSessionId) { } @GuardedBy("lock") - private void createNewJobMasterServiceProcess(UUID leaderSessionId) throws FlinkException { + private void createNewJobMasterServiceProcess(UUID leaderSessionId) { Preconditions.checkState(jobMasterServiceProcess.closeAsync().isDone()); LOG.info(