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()

Reply via email to