Repository: metron Updated Branches: refs/heads/master cf404f77d -> 62de8bd8f
METRON-1284 Remove extraneous dead query in ElasticsearchDao (justinleet) closes apache/metron#818 Project: http://git-wip-us.apache.org/repos/asf/metron/repo Commit: http://git-wip-us.apache.org/repos/asf/metron/commit/62de8bd8 Tree: http://git-wip-us.apache.org/repos/asf/metron/tree/62de8bd8 Diff: http://git-wip-us.apache.org/repos/asf/metron/diff/62de8bd8 Branch: refs/heads/master Commit: 62de8bd8f1dff43a319ae9b58c69876cd23211e7 Parents: cf404f7 Author: justinleet <[email protected]> Authored: Fri Oct 27 09:43:13 2017 -0400 Committer: leet <[email protected]> Committed: Fri Oct 27 09:43:13 2017 -0400 ---------------------------------------------------------------------- .../org/apache/metron/elasticsearch/dao/ElasticsearchDao.java | 6 ------ 1 file changed, 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/metron/blob/62de8bd8/metron-platform/metron-elasticsearch/src/main/java/org/apache/metron/elasticsearch/dao/ElasticsearchDao.java ---------------------------------------------------------------------- diff --git a/metron-platform/metron-elasticsearch/src/main/java/org/apache/metron/elasticsearch/dao/ElasticsearchDao.java b/metron-platform/metron-elasticsearch/src/main/java/org/apache/metron/elasticsearch/dao/ElasticsearchDao.java index e423e56..f114b4c 100644 --- a/metron-platform/metron-elasticsearch/src/main/java/org/apache/metron/elasticsearch/dao/ElasticsearchDao.java +++ b/metron-platform/metron-elasticsearch/src/main/java/org/apache/metron/elasticsearch/dao/ElasticsearchDao.java @@ -301,12 +301,6 @@ public class ElasticsearchDao implements IndexDao { String existingIndex = calculateExistingIndex(update, index, indexPostfix); UpdateRequest updateRequest = buildUpdateRequest(update, sensorType, indexName, existingIndex); - - org.elasticsearch.action.search.SearchResponse result = client.prepareSearch("test*") - .setFetchSource(true) - .setQuery(QueryBuilders.matchAllQuery()) - .get(); - result.getHits(); try { UpdateResponse response = client.update(updateRequest).get();
