Skip to content

Commit d4b22e1

Browse files
committed
Enrich purge hits on CBE
1 parent c103451 commit d4b22e1

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

x-pack/plugin/enrich/src/main/java/org/elasticsearch/xpack/enrich/action/EnrichShardMultiSearchAction.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -271,6 +271,11 @@ protected MultiSearchResponse shardOperation(Request request, ShardId shardId) t
271271
hits[j] = hit;
272272
} catch (CircuitBreakingException e) {
273273
hit.decRef();
274+
for (SearchHit searchHit : hits) {
275+
if (searchHit != null) {
276+
searchHit.decRef();
277+
}
278+
}
274279
throw e;
275280
}
276281
}

0 commit comments

Comments
 (0)