diff --git a/pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataCacheTest.java b/pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataCacheTest.java index 1c663abd3272e..0cf2369ea6dc2 100644 --- a/pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataCacheTest.java +++ b/pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataCacheTest.java @@ -611,7 +611,7 @@ public static void assertEqualsAndRetry(Supplier actual, public static boolean retryStrategically(Predicate predicate, int retryCount, long intSleepTimeInMillis) throws Exception { for (int i = 0; i < retryCount; i++) { - if (predicate.test(null) || i == (retryCount - 1)) { + if (predicate.test(null)) { return true; } Thread.sleep(intSleepTimeInMillis + (intSleepTimeInMillis * i));