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..770a4b6 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 @@ -101,13 +101,6 @@ public AllocationFileLoaderService(Clock clock) { public void init(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,6 +134,13 @@ public void run() { }; reloadThread.setName("AllocationFileReloader"); reloadThread.setDaemon(true); + } + + @Override + public void start() { + if (allocFile == null) { + return; + } reloadThread.start(); super.start(); }