Skip to content

Commit 45ae8f6

Browse files
committed
lighter search holder
1 parent 23d2799 commit 45ae8f6

File tree

2 files changed

+8
-9
lines changed

2 files changed

+8
-9
lines changed

modules/elasticsearch/src/main/java/org/elasticsearch/index/engine/robin/RobinEngine.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,7 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine,
150150
IndexReader indexReader = indexWriter.getReader();
151151
IndexSearcher indexSearcher = new IndexSearcher(indexReader);
152152
indexSearcher.setSimilarity(similarityService.defaultSearchSimilarity());
153-
this.nrtResource = newAcquirableResource(new ReaderSearcherHolder(indexReader, indexSearcher));
153+
this.nrtResource = newAcquirableResource(new ReaderSearcherHolder(indexSearcher));
154154
} catch (IOException e) {
155155
try {
156156
indexWriter.rollback();
@@ -257,7 +257,9 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine,
257257
AcquirableResource<ReaderSearcherHolder> current = nrtResource;
258258
IndexReader newReader = current.resource().reader().reopen(true);
259259
if (newReader != current.resource().reader()) {
260-
nrtResource = newAcquirableResource(new ReaderSearcherHolder(newReader));
260+
IndexSearcher indexSearcher = new IndexSearcher(newReader);
261+
indexSearcher.setSimilarity(similarityService.defaultSearchSimilarity());
262+
nrtResource = newAcquirableResource(new ReaderSearcherHolder(indexSearcher));
261263
current.markForClose();
262264
}
263265
}

modules/elasticsearch/src/main/java/org/elasticsearch/util/lucene/ReaderSearcherHolder.java

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -31,21 +31,18 @@
3131
*/
3232
public class ReaderSearcherHolder implements Releasable {
3333

34-
private final IndexReader indexReader;
35-
3634
private final IndexSearcher indexSearcher;
3735

3836
public ReaderSearcherHolder(IndexReader indexReader) {
39-
this(indexReader, new IndexSearcher(indexReader));
37+
this(new IndexSearcher(indexReader));
4038
}
4139

42-
public ReaderSearcherHolder(IndexReader indexReader, IndexSearcher indexSearcher) {
43-
this.indexReader = indexReader;
40+
public ReaderSearcherHolder(IndexSearcher indexSearcher) {
4441
this.indexSearcher = indexSearcher;
4542
}
4643

4744
public IndexReader reader() {
48-
return indexReader;
45+
return indexSearcher.getIndexReader();
4946
}
5047

5148
public IndexSearcher searcher() {
@@ -59,7 +56,7 @@ public IndexSearcher searcher() {
5956
// do nothing
6057
}
6158
try {
62-
indexReader.close();
59+
indexSearcher.getIndexReader().close();
6360
} catch (Exception e) {
6461
// do nothing
6562
}

0 commit comments

Comments
 (0)