Use correct index name
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/7000bd9c Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/7000bd9c Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/7000bd9c Branch: refs/heads/two-dot-o-events Commit: 7000bd9c424a0ada98b03d0564385ae0b6933daf Parents: 7dec37b Author: Dave Johnson <[email protected]> Authored: Fri Oct 31 14:00:44 2014 -0400 Committer: Dave Johnson <[email protected]> Committed: Fri Oct 31 14:00:44 2014 -0400 ---------------------------------------------------------------------- .../usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/7000bd9c/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java index ca7f666..aedee2b 100644 --- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java +++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexBatchImpl.java @@ -203,7 +203,7 @@ public class EsEntityIndexBatchImpl implements EntityIndexBatch { TermQueryBuilder tqb = QueryBuilders.termQuery( STRING_PREFIX + ENTITYID_FIELDNAME, entityId.getUuid().toString().toLowerCase()); - DeleteByQueryResponse response = client.prepareDeleteByQuery("test") + DeleteByQueryResponse response = client.prepareDeleteByQuery( indexName ) .setQuery( tqb ).execute().actionGet(); logger.debug("Deleted entity {}:{} from all index scopes with response status = {}", @@ -222,7 +222,7 @@ public class EsEntityIndexBatchImpl implements EntityIndexBatch { ( STRING_PREFIX + ENTITYID_FIELDNAME,entity.getId().getUuid().toString().toLowerCase() ), FilterBuilders.rangeFilter("version").lt( entity.getId().getUuid().timestamp() )); - DeleteByQueryResponse response = client.prepareDeleteByQuery("test") + DeleteByQueryResponse response = client.prepareDeleteByQuery( indexName ) .setQuery( fqb ).execute().actionGet(); logger.debug("Deleted entity {}:{} from all index scopes with response status = {}",
