stale index cleanup passes
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/4907b221 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/4907b221 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/4907b221 Branch: refs/heads/two-dot-o-dev Commit: 4907b2212476e05684e51e3a81293f344a13e08b Parents: 0465628 Author: Shawn Feldman <[email protected]> Authored: Fri May 8 13:07:55 2015 -0600 Committer: Shawn Feldman <[email protected]> Committed: Fri May 8 13:07:55 2015 -0600 ---------------------------------------------------------------------- .../pipeline/read/elasticsearch/CandidateEntityFilter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/4907b221/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/read/elasticsearch/CandidateEntityFilter.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/read/elasticsearch/CandidateEntityFilter.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/read/elasticsearch/CandidateEntityFilter.java index d30917c..4304b37 100644 --- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/read/elasticsearch/CandidateEntityFilter.java +++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/read/elasticsearch/CandidateEntityFilter.java @@ -203,7 +203,7 @@ public class CandidateEntityFilter extends AbstractFilter<Candidate, Entity> logger.warn( "Deindexing stale entity on edge {} for entityId {} and version {}", new Object[] { searchEdge, entityId, entityVersion } ); - batch.deindex( searchEdge, entityId, entityVersion ); + batch.deindex( searchEdge, entityId, candidateVersion ); return; }
