diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AllocationFileLoaderService.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AllocationFileLoaderService.java index 6c35630..0ddfba5 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AllocationFileLoaderService.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/AllocationFileLoaderService.java @@ -98,16 +98,9 @@ public AllocationFileLoaderService(Clock clock) { } @Override - public void init(Configuration conf) { + public void serviceInit(Configuration conf) { this.allocFile = getAllocationFile(conf); super.init(conf); - } - - @Override - public void start() { - if (allocFile == null) { - return; - } reloadThread = new Thread() { public void run() { while (running) { @@ -141,12 +134,19 @@ public void run() { }; reloadThread.setName("AllocationFileReloader"); reloadThread.setDaemon(true); + } + + @Override + public void serviceStart() { + if (allocFile == null) { + return; + } reloadThread.start(); super.start(); } @Override - public void stop() { + public void serviceStop() { running = false; if (reloadThread != null) { reloadThread.interrupt();