Skip to content

Commit 00c4f59

Browse files
authored
Fix resource leak in CrossClusterSearchUnavailableClusterIT (#124880) (#124909)
Fixes #123814
1 parent b3630d4 commit 00c4f59

File tree

1 file changed

+12
-2
lines changed

1 file changed

+12
-2
lines changed

qa/ccs-unavailable-clusters/src/javaRestTest/java/org/elasticsearch/search/CrossClusterSearchUnavailableClusterIT.java

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,12 @@ private static MockTransportService startTransport(
9494
EsExecutors.DIRECT_EXECUTOR_SERVICE,
9595
SearchShardsRequest::new,
9696
(request, channel, task) -> {
97-
channel.sendResponse(new SearchShardsResponse(List.of(), List.of(), Collections.emptyMap()));
97+
var searchShardsResponse = new SearchShardsResponse(List.of(), List.of(), Collections.emptyMap());
98+
try {
99+
channel.sendResponse(searchShardsResponse);
100+
} finally {
101+
searchShardsResponse.decRef();
102+
}
98103
}
99104
);
100105
newService.registerRequestHandler(
@@ -135,7 +140,12 @@ private static MockTransportService startTransport(
135140
builder.add(node);
136141
}
137142
ClusterState build = ClusterState.builder(clusterName).nodes(builder.build()).build();
138-
channel.sendResponse(new ClusterStateResponse(clusterName, build, false));
143+
var clusterStateResponse = new ClusterStateResponse(clusterName, build, false);
144+
try {
145+
channel.sendResponse(clusterStateResponse);
146+
} finally {
147+
clusterStateResponse.decRef();
148+
}
139149
}
140150
);
141151
newService.start();

0 commit comments

Comments
 (0)