|
@@ -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 {
|