diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/CuratorBasedElectorService.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/CuratorBasedElectorService.java index 660b118faff..ed5a2eb421d 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/CuratorBasedElectorService.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/CuratorBasedElectorService.java @@ -63,10 +63,15 @@ protected void serviceInit(Configuration conf) throws Exception { YarnConfiguration.DEFAULT_AUTO_FAILOVER_ZK_BASE_PATH); latchPath = zkBasePath + "/" + clusterId; curator = rm.getCurator(); - initAndStartLeaderLatch(); super.serviceInit(conf); } + @Override + protected void serviceStart() throws Exception{ + initAndStartLeaderLatch(); + super.serviceStart(); + } + private void initAndStartLeaderLatch() throws Exception { leaderLatch = new LeaderLatch(curator, latchPath, rmId); leaderLatch.addListener(this);