Repository: incubator-geode Updated Branches: refs/heads/develop 90e00bf97 -> 983010e4a
GEODE-1671: It's a test issue. The accessor is a datastore. So it should be pauseSender too. Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/983010e4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/983010e4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/983010e4 Branch: refs/heads/develop Commit: 983010e4a1768c33ff24ac595421240903cdf489 Parents: 90e00bf Author: zhouxh <gz...@pivotal.io> Authored: Mon Aug 1 09:05:05 2016 -0700 Committer: zhouxh <gz...@pivotal.io> Committed: Mon Aug 1 09:07:06 2016 -0700 ---------------------------------------------------------------------- .../cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/983010e4/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java b/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java index dc86a7c..d509cb2 100644 --- a/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java +++ b/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java @@ -100,11 +100,13 @@ public class LuceneQueriesPeerPRRedundancyDUnitTest extends LuceneQueriesPRBase accessor.invoke(() -> initAccessor(createIndex)); dataStore1.invoke(() -> LuceneTestUtilities.pauseSender(getCache())); dataStore2.invoke(() -> LuceneTestUtilities.pauseSender(getCache())); + accessor.invoke(() -> LuceneTestUtilities.pauseSender(getCache())); putEntryInEachBucket(); dataStore1.invoke(() -> LuceneTestUtilities.resumeSender(getCache())); dataStore2.invoke(() -> LuceneTestUtilities.resumeSender(getCache())); + accessor.invoke(() -> LuceneTestUtilities.resumeSender(getCache())); assertTrue(waitForFlushBeforeExecuteTextSearch(dataStore2, 60000));
