geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From n...@apache.org
Subject geode git commit: GEODE-2548: Removing the test alternativelyCloseDataStoresAfterGettingAPageAndThenValidateTheContentsOfTheResults
Date Mon, 13 Mar 2017 19:10:25 GMT
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 <nnag@pivotal.io>
Authored: Mon Mar 13 12:03:07 2017 -0700
Committer: nabarun <nnag@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()


Mime
View raw message