Skip to content

Commit b08ec09

Browse files
committed
Fix ClusterInfoServiceIT#testMaxQueueLatenciesInClusterInfo
Closes: #134500
1 parent 42b0876 commit b08ec09

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

muted-tests.yml

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -444,9 +444,6 @@ tests:
444444
- class: org.elasticsearch.action.admin.cluster.state.TransportClusterStateActionTests
445445
method: testGetClusterStateWithDefaultProjectOnly
446446
issue: https://github.com/elastic/elasticsearch/issues/134450
447-
- class: org.elasticsearch.cluster.ClusterInfoServiceIT
448-
method: testMaxQueueLatenciesInClusterInfo
449-
issue: https://github.com/elastic/elasticsearch/issues/134500
450447
- class: org.elasticsearch.xpack.esql.expression.function.scalar.score.DecayTests
451448
method: "testEvaluateBlockWithNulls {TestCase=<date_nanos>, <date_nanos>, <time_duration>, <_source> #11}"
452449
issue: https://github.com/elastic/elasticsearch/issues/134509

server/src/internalClusterTest/java/org/elasticsearch/cluster/ClusterInfoServiceIT.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -514,6 +514,8 @@ public void testMaxQueueLatenciesInClusterInfo() throws Exception {
514514
threadsToJoin[i].join();
515515
}
516516
Arrays.stream(threadsToJoin).forEach(thread -> assertFalse(thread.isAlive()));
517+
// Wait for the write executor to go idle
518+
assertBusy(() -> assertThat(trackingWriteExecutor.getActiveCount(), equalTo(0)));
517519

518520
assertThat(
519521
"Unexpectedly found a task queued for the write thread pool. Write thread pool dump: " + trackingWriteExecutor,

0 commit comments

Comments
 (0)