commit | d99034ee4ce79b5d685aaefd84b5b89005880dbc | [log] [tgz] |
---|---|---|
author | Matthias Pohl <github@mapohl.com> | Tue Nov 26 08:23:09 2024 +0100 |
committer | Matthias Pohl <github@mapohl.com> | Mon Dec 09 17:22:45 2024 +0100 |
tree | 71a6d611742b9108c084b2fee83cf20d4f9cf4bf | |
parent | 6a214e1e24677f121073aea31918f978833b79bc [diff] |
[hotfix][runtime] Removes unused FlinkException in signature
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 875e4ca..a3bb244 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 @@ } @GuardedBy("lock") - private void createNewJobMasterServiceProcess(UUID leaderSessionId) throws FlinkException { + private void createNewJobMasterServiceProcess(UUID leaderSessionId) { Preconditions.checkState(jobMasterServiceProcess.closeAsync().isDone()); LOG.info(