@@ -168,7 +168,6 @@ public void testForceMergeIsBlockedThenUnblocked() throws Exception {
168168 setTotalSpace (node , Long .MAX_VALUE );
169169 ThreadPoolMergeExecutorService threadPoolMergeExecutorService = internalCluster ().getInstance (IndicesService .class , node )
170170 .getThreadPoolMergeExecutorService ();
171- TestTelemetryPlugin testTelemetryPlugin = getTelemetryPlugin (node );
172171 // create some index
173172 final String indexName = randomAlphaOfLength (10 ).toLowerCase (Locale .ROOT );
174173 createIndex (
@@ -228,7 +227,6 @@ public void testForceMergeIsBlockedThenUnblocked() throws Exception {
228227 // wait for the merge call to return
229228 safeGet (forceMergeFuture );
230229 IndicesStatsResponse indicesStatsResponse = indicesAdmin ().prepareStats (indexName ).setMerge (true ).get ();
231- testTelemetryPlugin .collect ();
232230 // assert index stats and telemetry report no merging in progress (after force merge returned)
233231 long currentMergeCount = indicesStatsResponse .getIndices ().get (indexName ).getPrimaries ().merge .getCurrent ();
234232 assertThat (currentMergeCount , equalTo (0L ));
@@ -246,13 +244,4 @@ public void setTotalSpace(String dataNodeName, long totalSpace) {
246244 getTestFileStore (dataNodeName ).setTotalSpace (totalSpace );
247245 refreshClusterInfo ();
248246 }
249-
250- private TestTelemetryPlugin getTelemetryPlugin (String dataNodeName ) {
251- var plugin = internalCluster ().getInstance (PluginsService .class , dataNodeName )
252- .filterPlugins (TestTelemetryPlugin .class )
253- .findFirst ()
254- .orElseThrow ();
255- plugin .resetMeter ();
256- return plugin ;
257- }
258247}
0 commit comments