You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by zh...@apache.org on 2017/04/27 18:48:14 UTC
[39/40] geode git commit: fix-4
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 {