diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
index da63d13be7a03b1b1e4a3e855022965ee7b6d8a2..f4745cf8be664964b903780f8f90b66f46af0905 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
@@ -1734,6 +1734,8 @@ public class AdminApiTest extends MockedPulsarServiceBaseTest {
 
         // (1) update partitions
         admin.persistentTopics().updatePartitionedTopic(partitionedTopicName, newPartitions);
+        // invalidate global-cache to make sure that mock-zk-cache reds fresh data
+        pulsar.getGlobalZkCache().invalidateAll();
         // verify new partitions have been created
         assertEquals(admin.persistentTopics().getPartitionedTopicMetadata(partitionedTopicName).partitions,
                 newPartitions);
@@ -1755,6 +1757,8 @@ public class AdminApiTest extends MockedPulsarServiceBaseTest {
         // newly created partition topics
         consumer2.close();
         consumer2 = client.subscribe(partitionedTopicName, subName2, conf);
+        // sometime: mockZk fails to refresh ml-cache: so, invalidate the cache to get fresh data
+        pulsar.getLocalZkCacheService().managedLedgerListCache().clearTree();
         assertEquals(Sets.newHashSet(admin.persistentTopics().getSubscriptions(newPartitionTopicName)),
                 Sets.newHashSet(subName1, subName2));