diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt index 7fa83bec42e..6f23eeec165 100644 --- a/hadoop-yarn-project/CHANGES.txt +++ b/hadoop-yarn-project/CHANGES.txt @@ -465,6 +465,9 @@ Release 2.6.0 - UNRELEASED YARN-2608. FairScheduler: Potential deadlocks in loading alloc files and clock access. (Wei Yan via kasha) + YARN-2606. Application History Server tries to access hdfs before doing + secure login (Mit Desai via jeagles) + Release 2.5.1 - 2014-09-05 INCOMPATIBLE CHANGES diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/FileSystemApplicationHistoryStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/FileSystemApplicationHistoryStore.java index 7840dd18660..6d76864b07f 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/FileSystemApplicationHistoryStore.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/FileSystemApplicationHistoryStore.java @@ -115,7 +115,8 @@ protected FileSystem getFileSystem(Path path, Configuration conf) throws Excepti } @Override - public void serviceInit(Configuration conf) throws Exception { + public void serviceStart() throws Exception { + Configuration conf = getConfig(); Path fsWorkingPath = new Path(conf.get(YarnConfiguration.FS_APPLICATION_HISTORY_STORE_URI, conf.get("hadoop.tmp.dir") + "/yarn/timeline/generic-history")); @@ -132,7 +133,7 @@ public void serviceInit(Configuration conf) throws Exception { LOG.error("Error when initializing FileSystemHistoryStorage", e); throw e; } - super.serviceInit(conf); + super.serviceStart(); } @Override diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/TestFileSystemApplicationHistoryStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/TestFileSystemApplicationHistoryStore.java index 552a5e50b0e..4ac6f4d0aba 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/TestFileSystemApplicationHistoryStore.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/TestFileSystemApplicationHistoryStore.java @@ -61,10 +61,10 @@ public class TestFileSystemApplicationHistoryStore extends @Before public void setup() throws Exception { fs = new RawLocalFileSystem(); - initStore(fs); + initAndStartStore(fs); } - private void initStore(final FileSystem fs) throws IOException, + private void initAndStartStore(final FileSystem fs) throws IOException, URISyntaxException { Configuration conf = new Configuration(); fs.initialize(new URI("/"), conf); @@ -272,7 +272,7 @@ public void testInitExistingWorkingDirectoryInSafeMode() throws Exception { doReturn(true).when(fs).isDirectory(any(Path.class)); try { - initStore(fs); + initAndStartStore(fs); } catch (Exception e) { Assert.fail("Exception should not be thrown: " + e); } @@ -293,7 +293,7 @@ public void testInitNonExistingWorkingDirectoryInSafeMode() throws Exception { doThrow(new IOException()).when(fs).mkdirs(any(Path.class)); try { - initStore(fs); + initAndStartStore(fs); Assert.fail("Exception should have been thrown"); } catch (Exception e) { // Expected failure