fix-4
Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/26338f7b Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/26338f7b Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/26338f7b Branch: refs/heads/feature/GEM-1299 Commit: 26338f7b5b5e7f4e89228e7d4d5dbb73662d8571 Parents: 675f0ef Author: zhouxh <gz...@pivotal.io> Authored: Fri Apr 21 09:28:21 2017 -0700 Committer: zhouxh <gz...@pivotal.io> Committed: Thu Apr 27 11:47:01 2017 -0700 ---------------------------------------------------------------------- .../cache/lucene/internal/LuceneIndexForPartitionedRegion.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/geode/blob/26338f7b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/LuceneIndexForPartitionedRegion.java ---------------------------------------------------------------------- diff --git a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/LuceneIndexForPartitionedRegion.java b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/LuceneIndexForPartitionedRegion.java index dbd31ba..a60ca01 100644 --- a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/LuceneIndexForPartitionedRegion.java +++ b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/LuceneIndexForPartitionedRegion.java @@ -292,7 +292,7 @@ public class LuceneIndexForPartitionedRegion extends LuceneIndexImpl { if (!br.getBucketAdvisor().isPrimary()) { AsyncEvent currentFirst = (AsyncEvent) ((BucketRegionQueue) br).firstEventSeqNum(); AsyncEvent lastPeek = (AsyncEvent) lastPeekedEvents.put(br, currentFirst); - if (currentFirst.equals(lastPeek)) { + if (currentFirst != null && currentFirst.equals(lastPeek)) { redistributeEvents(lastPeek); } } else {