geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zho...@apache.org
Subject [39/40] geode git commit: fix-4
Date Thu, 27 Apr 2017 18:48:14 GMT
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 <gzhou@pivotal.io>
Authored: Fri Apr 21 09:28:21 2017 -0700
Committer: zhouxh <gzhou@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 {


Mime
View raw message