Fix terms aggregations on indexers (#1178)

* Fix terms aggregation bug on indexer nodes * Formatting
slackhq · Dec 13, 2024 · e64b486 · e64b486
1 parent c8e587f
commit e64b486
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/astra/src/main/java/com/slack/astra/logstore/LuceneIndexStoreImpl.java b/astra/src/main/java/com/slack/astra/logstore/LuceneIndexStoreImpl.java
@@ -34,6 +34,8 @@
 import org.apache.lucene.search.SortField;
 import org.apache.lucene.store.FSDirectory;
 import org.apache.lucene.store.MMapDirectory;
+import org.opensearch.common.lucene.index.OpenSearchDirectoryReader;
+import org.opensearch.core.index.shard.ShardId;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -142,7 +144,11 @@ public LuceneIndexStoreImpl(
     RedactionFilterDirectoryReader reader =
         new RedactionFilterDirectoryReader(
             DirectoryReader.open(indexWriter.get(), false, false), fieldRedactionMetadataStore);
-    this.searcherManager = new SearcherManager(reader, null);
+    OpenSearchDirectoryReader openSearchDirectoryReader =
+        OpenSearchDirectoryReader.wrap(
+            reader,
+            ShardId.fromString("[shard-index][%d]".formatted(UUID.fromString(id).hashCode())));
+    this.searcherManager = new SearcherManager(openSearchDirectoryReader, null);
 
     scheduledCommit.scheduleWithFixedDelay(
         () -> {