diff --git a/modules/cache-common/src/internalClusterTest/java/org/opensearch/cache/common/tier/TieredSpilloverCacheStatsIT.java b/modules/cache-common/src/internalClusterTest/java/org/opensearch/cache/common/tier/TieredSpilloverCacheStatsIT.java index c72fc0d529c03..050da6f7db421 100644 --- a/modules/cache-common/src/internalClusterTest/java/org/opensearch/cache/common/tier/TieredSpilloverCacheStatsIT.java +++ b/modules/cache-common/src/internalClusterTest/java/org/opensearch/cache/common/tier/TieredSpilloverCacheStatsIT.java @@ -430,7 +430,7 @@ public void testClosingShard() throws Exception { // Closing the index should close the shard assertAcked(client().admin().indices().delete(new DeleteIndexRequest("index")).get()); - assertEquals(new ImmutableCacheStats(0, 0, 0, 0, 0), getTotalStats(client)); + assertBusy(() -> assertEquals(new ImmutableCacheStats(0, 0, 0, 0, 0), getTotalStats(client))); } private void startIndex(Client client, String indexName) throws InterruptedException {