From 052ca00aea1af3fca82098714201b4e555f1e77e Mon Sep 17 00:00:00 2001 From: Rajan Dhabalia Date: Fri, 4 Aug 2017 19:07:09 -0700 Subject: [PATCH] fix: intermittent test by invalidating cache to read fresh data (#642) --- .../java/org/apache/pulsar/broker/admin/AdminApiTest.java | 4 ++++ 1 file changed, 4 insertions(+) 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 da63d13be7a..f4745cf8be6 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)); -- GitLab