You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2015/10/25 04:15:23 UTC
usergrid git commit: Since delete event is also being used for read
repair, there are possibilities where the ES documents are already removed,
but entities and edges need cleaned from c*. Don't validate empty sets
returned from processing the event as
Repository: usergrid
Updated Branches:
refs/heads/USERGRID-1052 6e34b20b7 -> b025dda98
Since delete event is also being used for read repair, there are possibilities where the ES documents are already removed, but entities and edges need cleaned from c*. Don't validate empty sets returned from processing the event as it's a possible happy path case.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/b025dda9
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/b025dda9
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/b025dda9
Branch: refs/heads/USERGRID-1052
Commit: b025dda98f97b964df9b63a5622aa3a735d2813a
Parents: 6e34b20
Author: Michael Russo <mi...@gmail.com>
Authored: Sat Oct 24 20:15:21 2015 -0700
Committer: Michael Russo <mi...@gmail.com>
Committed: Sat Oct 24 20:15:21 2015 -0700
----------------------------------------------------------------------
.../corepersistence/asyncevents/AmazonAsyncEventService.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/b025dda9/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
index fe53776..d93e304 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java
@@ -324,6 +324,8 @@ public class AmazonAsyncEventService implements AsyncEventService {
}
else if ( event instanceof EntityDeleteEvent ) {
indexoperationObservable = handleEntityDelete( message );
+ validateEmptySets = false; // do not check this one for an empty set b/c it can be empty
+
}
else if ( event instanceof EntityIndexEvent ) {
indexoperationObservable = handleEntityIndexUpdate( message );