You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/07/19 09:28:52 UTC
[flink] branch master updated: [FLINK-13186][clients] Remove unused
fields
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new f762451 [FLINK-13186][clients] Remove unused fields
f762451 is described below
commit f7624518a9a89ef8a3ca2f9fa12d0859f5e72096
Author: vinoyang <ya...@gmail.com>
AuthorDate: Fri Jul 19 17:28:38 2019 +0800
[FLINK-13186][clients] Remove unused fields
---
.../apache/flink/client/program/rest/RestClusterClient.java | 12 ------------
1 file changed, 12 deletions(-)
diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java b/flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
index 1d08992..9bc2a5a 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
@@ -139,12 +139,8 @@ public class RestClusterClient<T> extends ClusterClient<T> implements NewCluster
private final LeaderRetrievalService webMonitorRetrievalService;
- private final LeaderRetrievalService dispatcherRetrievalService;
-
private final LeaderRetriever webMonitorLeaderRetriever = new LeaderRetriever();
- private final LeaderRetriever dispatcherLeaderRetriever = new LeaderRetriever();
-
/** ExecutorService to run operations that can be retried on exceptions. */
private ScheduledExecutorService retryExecutorService;
@@ -193,14 +189,12 @@ public class RestClusterClient<T> extends ClusterClient<T> implements NewCluster
} else {
this.webMonitorRetrievalService = webMonitorRetrievalService;
}
- this.dispatcherRetrievalService = highAvailabilityServices.getDispatcherLeaderRetriever();
this.retryExecutorService = Executors.newSingleThreadScheduledExecutor(new ExecutorThreadFactory("Flink-RestClusterClient-Retry"));
startLeaderRetrievers();
}
private void startLeaderRetrievers() throws Exception {
this.webMonitorRetrievalService.start(webMonitorLeaderRetriever);
- this.dispatcherRetrievalService.start(dispatcherLeaderRetriever);
}
@Override
@@ -217,12 +211,6 @@ public class RestClusterClient<T> extends ClusterClient<T> implements NewCluster
}
try {
- dispatcherRetrievalService.stop();
- } catch (Exception e) {
- log.error("An error occurred during stopping the dispatcherLeaderRetriever", e);
- }
-
- try {
// we only call this for legacy reasons to shutdown components that are started in the ClusterClient constructor
super.shutdown();
} catch (Exception e) {