Skip to content

Commit eee890a

Browse files
authored
Fix resource leak in CrossClusterSearchUnavailableClusterIT (#124880)
Fixes #123814
1 parent b76048d commit eee890a

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
@@ -91,7 +91,12 @@ private static MockTransportService startTransport(
9191
EsExecutors.DIRECT_EXECUTOR_SERVICE,
9292
SearchShardsRequest::new,
9393
(request, channel, task) -> {
94-
channel.sendResponse(new SearchShardsResponse(List.of(), List.of(), Collections.emptyMap()));
94+
var searchShardsResponse = new SearchShardsResponse(List.of(), List.of(), Collections.emptyMap());
95+
try {
96+
channel.sendResponse(searchShardsResponse);
97+
} finally {
98+
searchShardsResponse.decRef();
99+
}
95100
}
96101
);
97102
newService.registerRequestHandler(
@@ -119,7 +124,12 @@ private static MockTransportService startTransport(
119124
builder.add(node);
120125
}
121126
ClusterState build = ClusterState.builder(clusterName).nodes(builder.build()).build();
122-
channel.sendResponse(new ClusterStateResponse(clusterName, build, false));
127+
var clusterStateResponse = new ClusterStateResponse(clusterName, build, false);
128+
try {
129+
channel.sendResponse(clusterStateResponse);
130+
} finally {
131+
clusterStateResponse.decRef();
132+
}
123133
}
124134
);
125135
newService.start();

0 commit comments

Comments
 (0)