Skip to content

Commit c796d16

Browse files
adjust
1 parent f503fa7 commit c796d16

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/src/main/java/org/elasticsearch/action/search/SearchQueryThenFetchAsyncAction.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -226,7 +226,7 @@ public static final class NodeQueryResponse extends TransportResponse {
226226
) {
227227
this.results = results;
228228
for (Object result : results) {
229-
if (result instanceof RefCounted r) {
229+
if (result instanceof QuerySearchResult r) {
230230
r.incRef();
231231
}
232232
}
@@ -275,7 +275,7 @@ public boolean hasReferences() {
275275
public boolean decRef() {
276276
if (refCounted.decRef()) {
277277
for (int i = 0; i < results.length; i++) {
278-
if (results[i] instanceof RefCounted r) {
278+
if (results[i] instanceof QuerySearchResult r) {
279279
r.decRef();
280280
}
281281
results[i] = null;

0 commit comments

Comments
 (0)