Skip to content

Commit 095471c

Browse files
committed
Clear mock transport service rules in DataNodeRequestSenderIT
1 parent f31bd69 commit 095471c

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/plugin/DataNodeRequestSenderIT.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -153,6 +153,10 @@ public void testRetryOnShardMovement() {
153153

154154
try (EsqlQueryResponse resp = run("FROM " + randomFrom("index-1,index-2", "index-*"))) {
155155
assertThat(getValuesList(resp), hasSize(2));
156+
} finally {
157+
for (TransportService transportService : internalCluster().getInstances(TransportService.class)) {
158+
as(transportService, MockTransportService.class).clearAllRules();
159+
}
156160
}
157161
}
158162
}

0 commit comments

Comments
 (0)