Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-9009 Fix flaky test TestEntityGroupFSTimelineStore.testCleanLogs

This commit is contained in:
OrDTesters 2018-11-11 20:25:21 -06:00
parent b5ec85d966
commit db8e046352
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timeline-pluginstorage/src/test/java/org/apache/hadoop/yarn/server/timeline/TestEntityGroupFSTimelineStore.java
View File

@ -70,7 +70,7 @@ public class TestEntityGroupFSTimelineStore extends TimelineStoreTestUtils {
private static final String SAMPLE_APP_PREFIX_CACHE_TEST = "1234_000"; private static final String SAMPLE_APP_PREFIX_CACHE_TEST = "1234_000";
private static final int CACHE_TEST_CACHE_SIZE = 5; private static final int CACHE_TEST_CACHE_SIZE = 5;
private static final String TEST_SUMMARY_LOG_FILE_NAME private static final String TEST_SUMMARY_LOG_FILE_NAME
= EntityGroupFSTimelineStore.SUMMARY_LOG_PREFIX + "test"; = EntityGroupFSTimelineStore.SUMMARY_LOG_PREFIX + "test";
private static final String TEST_DOMAIN_LOG_FILE_NAME private static final String TEST_DOMAIN_LOG_FILE_NAME
@ -234,6 +234,8 @@ public class TestEntityGroupFSTimelineStore extends TimelineStoreTestUtils {
Path pathAfter = appLogs.getAppDirPath(); Path pathAfter = appLogs.getAppDirPath();
assertNotEquals(pathBefore, pathAfter); assertNotEquals(pathBefore, pathAfter);
assertTrue(pathAfter.toString().contains(testDoneDirPath.toString())); assertTrue(pathAfter.toString().contains(testDoneDirPath.toString()));
fs.delete(pathAfter, true);
} }
@Test @Test
@ -483,7 +485,7 @@ public class TestEntityGroupFSTimelineStore extends TimelineStoreTestUtils {
AppState appstate) { AppState appstate) {
// stop before creating new store to get the lock // stop before creating new store to get the lock
store.stop(); store.stop();
EntityGroupFSTimelineStore newStore = new EntityGroupFSTimelineStore() { EntityGroupFSTimelineStore newStore = new EntityGroupFSTimelineStore() {
@Override @Override
protected AppState getAppState(ApplicationId appId) throws IOException { protected AppState getAppState(ApplicationId appId) throws IOException {