Repository: geode Updated Branches: refs/heads/feature/GEM-1299 146d5c854 -> be448673d
fix-4 Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/be448673 Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/be448673 Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/be448673 Branch: refs/heads/feature/GEM-1299 Commit: be448673d7e961e65dd67489ede7938fec4fd10d Parents: 146d5c8 Author: zhouxh <[email protected]> Authored: Fri Apr 21 09:28:21 2017 -0700 Committer: zhouxh <[email protected]> Committed: Fri Apr 21 09:28:21 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/be448673/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 {
