You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2019/07/10 09:36:12 UTC
[flink] 11/16: [hotfix] [runtime] Remove obsolete Exception from
JobLeaderIdService signature
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 15d8cd5458a7a940cef16760b465abee4f20a06c
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Tue Jul 9 16:18:42 2019 +0200
[hotfix] [runtime] Remove obsolete Exception from JobLeaderIdService signature
---
.../org/apache/flink/runtime/resourcemanager/JobLeaderIdService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/JobLeaderIdService.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/JobLeaderIdService.java
old mode 100644
new mode 100755
index 994db34..98bc66b
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/JobLeaderIdService.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/JobLeaderIdService.java
@@ -68,7 +68,7 @@ public class JobLeaderIdService {
public JobLeaderIdService(
HighAvailabilityServices highAvailabilityServices,
ScheduledExecutor scheduledExecutor,
- Time jobTimeout) throws Exception {
+ Time jobTimeout) {
this.highAvailabilityServices = Preconditions.checkNotNull(highAvailabilityServices, "highAvailabilityServices");
this.scheduledExecutor = Preconditions.checkNotNull(scheduledExecutor, "scheduledExecutor");
this.jobTimeout = Preconditions.checkNotNull(jobTimeout, "jobTimeout");