fix(usage-stats): add indices target for usage stats query (#2798)

datahub-project · Jun 29, 2021 · 2ee9ecf · 2ee9ecf
1 parent 79f60d8
commit 2ee9ecf
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/metadata-io/src/main/java/com/linkedin/metadata/usage/elasticsearch/ElasticUsageService.java b/metadata-io/src/main/java/com/linkedin/metadata/usage/elasticsearch/ElasticUsageService.java
@@ -191,6 +191,10 @@ public List<UsageAggregation> query(@Nonnull String resource, @Nonnull WindowDur
 
         final SearchRequest searchRequest = new SearchRequest();
         searchRequest.source(searchSourceBuilder);
+
+        final String indexName = indexConvention.getIndexName(USAGE_STATS_BASE_INDEX_NAME);
+        searchRequest.indices(indexName);
+
         log.debug("Search request is: " + searchRequest.toString());
 
         try {