big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

YARN-6385. Fix checkstyle warnings in TestFileSystemApplicationHistoryStore

Browse Source 
Signed-off-by: Akira Ajisaka <aajisaka@apache.org>
This commit is contained in:
Yiqun Lin 2018-05-02 18:14:02 +09:00 committed by Akira Ajisaka
parent e07156e8b0
commit 3265b55119
No known key found for this signature in database
GPG Key ID: C1EDBB9CA400FD50
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-applicationhistoryservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/TestFileSystemApplicationHistoryStore.java
View File

@ -272,20 +272,20 @@ public void testInitExistingWorkingDirectoryInSafeMode() throws Exception {
tearDown();
// Setup file system to inject startup conditions
FileSystem fs = spy(new RawLocalFileSystem());
FileSystem fileSystem = spy(new RawLocalFileSystem());
FileStatus fileStatus = Mockito.mock(FileStatus.class);
doReturn(true).when(fileStatus).isDirectory();
doReturn(fileStatus).when(fs).getFileStatus(any(Path.class));
doReturn(fileStatus).when(fileSystem).getFileStatus(any(Path.class));
try {
initAndStartStore(fs);
initAndStartStore(fileSystem);
} catch (Exception e) {
Assert.fail("Exception should not be thrown: " + e);
}
// Make sure that directory creation was not attempted
verify(fileStatus, never()).isDirectory();
verify(fs, times(1)).mkdirs(any(Path.class));
verify(fileSystem, times(1)).mkdirs(any(Path.class));
}
@Test
@ -294,14 +294,14 @@ public void testInitNonExistingWorkingDirectoryInSafeMode() throws Exception {
tearDown();
// Setup file system to inject startup conditions
FileSystem fs = spy(new RawLocalFileSystem());
FileSystem fileSystem = spy(new RawLocalFileSystem());
FileStatus fileStatus = Mockito.mock(FileStatus.class);
doReturn(false).when(fileStatus).isDirectory();
doReturn(fileStatus).when(fs).getFileStatus(any(Path.class));
doThrow(new IOException()).when(fs).mkdirs(any(Path.class));
doReturn(fileStatus).when(fileSystem).getFileStatus(any(Path.class));
doThrow(new IOException()).when(fileSystem).mkdirs(any(Path.class));
try {
initAndStartStore(fs);
initAndStartStore(fileSystem);
Assert.fail("Exception should have been thrown");
} catch (Exception e) {
// Expected failure
@ -309,6 +309,6 @@ public void testInitNonExistingWorkingDirectoryInSafeMode() throws Exception {
// Make sure that directory creation was attempted
verify(fileStatus, never()).isDirectory();
verify(fs, times(1)).mkdirs(any(Path.class));
verify(fileSystem, times(1)).mkdirs(any(Path.class));
}
}