YARN-8322. Change log level when there is an IOException when the allocation file is loaded. (Szilard Nemeth via Haibo Chen)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/676dcfff Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/676dcfff Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/676dcfff Branch: refs/heads/HADOOP-15461 Commit: 676dcffff575fdf1c4b49aeae4e000bd60ca0a83 Parents: c190ac2 Author: Haibo Chen <haiboc...@apache.org> Authored: Mon Jun 11 11:16:21 2018 -0700 Committer: Haibo Chen <haiboc...@apache.org> Committed: Mon Jun 11 11:16:21 2018 -0700 ---------------------------------------------------------------------- .../scheduler/fair/AllocationFileLoaderService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/676dcfff/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 ---------------------------------------------------------------------- diff --git a/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 b/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 e541ab7..32cb236 100644 --- a/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 +++ b/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 @@ -109,7 +109,7 @@ public class AllocationFileLoaderService extends AbstractService { @Override public void serviceInit(Configuration conf) throws Exception { this.allocFile = getAllocationFile(conf); - if(this.allocFile != null) { + if (this.allocFile != null) { this.fs = allocFile.getFileSystem(conf); reloadThread = new Thread(() -> { while (running) { @@ -138,7 +138,7 @@ public class AllocationFileLoaderService extends AbstractService { lastReloadAttemptFailed = true; } } catch (IOException e) { - LOG.info("Exception while loading allocation file: " + e); + LOG.error("Exception while loading allocation file: " + e); } try { Thread.sleep(reloadIntervalMs); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
