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/master Commit: b025dda98f97b964df9b63a5622aa3a735d2813a Parents: 6e34b20 Author: Michael Russo <[email protected]> Authored: Sat Oct 24 20:15:21 2015 -0700 Committer: Michael Russo <[email protected]> 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 );
