Repository: geode Updated Branches: refs/heads/develop 02ffd528f -> ebc1642fc
GEODE-2548: Removing the test alternativelyCloseDataStoresAfterGettingAPageAndThenValidateTheContentsOfTheResults * Removed the test as it was shutting down one datastore before the other datastore could recover from it. * The second datastore just keeps waiting (hang) to recover but the other datastore was shut down Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/ebc1642f Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/ebc1642f Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/ebc1642f Branch: refs/heads/develop Commit: ebc1642fc6914024e0091e156f65b53f19dbe7e8 Parents: 02ffd52 Author: nabarun <n...@pivotal.io> Authored: Mon Mar 13 12:03:07 2017 -0700 Committer: nabarun <n...@pivotal.io> Committed: Mon Mar 13 12:03:07 2017 -0700 ---------------------------------------------------------------------- .../geode/cache/lucene/PaginationDUnitTest.java | 54 -------------------- 1 file changed, 54 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/geode/blob/ebc1642f/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java index ad6727e..11d5cd0 100644 --- a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java +++ b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java @@ -138,60 +138,6 @@ public class PaginationDUnitTest extends LuceneQueriesAccessorBase { }); } - @Test - @Ignore - @Parameters(method = "getListOfRegionTestTypes") - public void alternativelyCloseDataStoresAfterGettingAPageAndThenValidateTheContentsOfTheResults( - RegionTestableType regionTestType) { - SerializableRunnableIF createIndex = () -> { - LuceneService luceneService = LuceneServiceProvider.get(getCache()); - luceneService.createIndexFactory().setFields("text").create(INDEX_NAME, REGION_NAME); - }; - - dataStore1.invoke(() -> initDataStore(createIndex, regionTestType)); - dataStore2.invoke(() -> initDataStore(createIndex, regionTestType)); - accessor.invoke(() -> initAccessor(createIndex, regionTestType)); - - putEntryInEachBucket(); - - assertTrue(waitForFlushBeforeExecuteTextSearch(dataStore1, FLUSH_WAIT_TIME_MS)); - - accessor.invoke(() -> { - List<LuceneResultStruct<Integer, TestObject>> combinedResult = - new ArrayList<LuceneResultStruct<Integer, TestObject>>(); - Cache cache = getCache(); - LuceneService service = LuceneServiceProvider.get(cache); - LuceneQuery<Integer, TestObject> query; - query = service.createLuceneQueryFactory().setResultLimit(1000).setPageSize(PAGE_SIZE) - .create(INDEX_NAME, REGION_NAME, "world", "text"); - PageableLuceneQueryResults<Integer, TestObject> pages = query.findPages(); - assertTrue(pages.hasNext()); - - dataStore1.invoke(() -> closeCache()); - dataStore2.invoke(() -> closeCache()); - - for (int i = 0; i < (NUM_BUCKETS / PAGE_SIZE); i++) { - List<LuceneResultStruct<Integer, TestObject>> page; - if (i % 2 == 0) { - // Bring up dataStore2 and shutdown dataStore1 - dataStore2.invoke(() -> initDataStore(createIndex, regionTestType)); - assertTrue(waitForFlushBeforeExecuteTextSearch(dataStore2, FLUSH_WAIT_TIME_MS)); - dataStore1.invoke(() -> closeCache()); - page = pages.next(); - } else { - // Bring up dataStore1 and shutdown dataStore2 - dataStore1.invoke(() -> initDataStore(createIndex, regionTestType)); - assertTrue(waitForFlushBeforeExecuteTextSearch(dataStore1, FLUSH_WAIT_TIME_MS)); - dataStore2.invoke(() -> closeCache()); - page = pages.next(); - } - assertEquals(PAGE_SIZE, page.size()); - combinedResult.addAll(page); - } - validateTheCombinedResult(combinedResult); - }); - } - private void validateTheCombinedResult( final List<LuceneResultStruct<Integer, TestObject>> combinedResult) { Map<Integer, TestObject> resultMap = combinedResult.stream()