commit c98a5e92d1f2bf2424624e6c1f76511a345f5d69
author Mike Dunker <mdunker@google.com> Thu Mar 08 15:05:09 2018 -0800
committer Keyur Karnik <keyur.karnik+github@gmail.com> Tue Aug 28 16:41:44 2018 -0700
tree e35c7091a3278af1d6afb57ddf4ce017ac1d265e
parent 1feb3dbab88145c9d5483b05bced03c2f6bafa79

fix deindex on update -- was deindexing current version along with old versions

stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java

diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java
index 1eb5e03..dbec084 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java
@@ -301,14 +301,14 @@
 
 
         return indexService.deIndexOldVersions( applicationScope, entityId,
-            getVersionsOlderThanOrEqualToMarked(ecm, entityId, markedVersion));
+            getVersionsOlderThanMarked(ecm, entityId, markedVersion));
 
 
     }
 
 
-    private List<UUID> getVersionsOlderThanOrEqualToMarked(final EntityCollectionManager ecm,
-                                                           final Id entityId, final UUID markedVersion ){
+    private List<UUID> getVersionsOlderThanMarked(final EntityCollectionManager ecm, final Id entityId,
+                                                  final UUID markedVersion ){
 
         final List<UUID> versions = new ArrayList<>();
 
@@ -317,7 +317,7 @@
         ecm.getVersionsFromMaxToMin( entityId, markedVersion)
             .take(100)
             .forEach( mvccLogEntry -> {
-                if ( mvccLogEntry.getVersion().timestamp() <= markedVersion.timestamp() ) {
+                if ( mvccLogEntry.getVersion().timestamp() < markedVersion.timestamp() ) {
                     versions.add(mvccLogEntry.getVersion());
                 }