diff --git a/server/src/test/java/org/elasticsearch/indices/IndexingMemoryControllerTests.java b/server/src/test/java/org/elasticsearch/indices/IndexingMemoryControllerTests.java
index 1431937245e..ccef3aa11e8 100644
--- a/server/src/test/java/org/elasticsearch/indices/IndexingMemoryControllerTests.java
+++ b/server/src/test/java/org/elasticsearch/indices/IndexingMemoryControllerTests.java
@@ -432,19 +432,18 @@ public class IndexingMemoryControllerTests extends IndexShardTestCase {
             }
         };
         int iterations = randomIntBetween(10, 100);
+        ThreadPoolStats.Stats beforeStats = getRefreshThreadPoolStats();
         for (int i = 0; i < iterations; i++) {
             controller.forceCheck();
         }
         assertBusy(() -> {
             ThreadPoolStats.Stats stats = getRefreshThreadPoolStats();
-            assertThat(stats.getQueue(), equalTo(0));
-            assertThat(stats.getActive(), equalTo(1));
+            assertThat(stats.getCompleted(), equalTo(beforeStats.getCompleted() + iterations - 1));
         });
         refreshLatch.get().countDown(); // allow refresh
         assertBusy(() -> {
             ThreadPoolStats.Stats stats = getRefreshThreadPoolStats();
-            assertThat(stats.getQueue(), equalTo(0));
-            assertThat(stats.getActive(), equalTo(0));
+            assertThat(stats.getCompleted(), equalTo(beforeStats.getCompleted() + iterations));
         });
         assertThat(shard.refreshStats().getTotal(), equalTo(refreshStats.getTotal() + 1));
         closeShards(shard);