fix: intermittent test failure due to invalid cache (apache#8405)

Jhanay · Oct 29, 2020 · 9d74007 · 9d74007
1 parent a9e2f7e
commit 9d74007
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Bookies.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Bookies.java
@@ -137,6 +137,7 @@ public void updateBookieRackInfo(@PathParam("bookie") String bookieAddress, @Que
 
             localZk().setData(ZkBookieRackAffinityMapping.BOOKIE_INFO_ROOT_PATH, jsonMapper().writeValueAsBytes(racks),
                     entry.get().getValue().getVersion());
+            localZkCache().invalidate(ZkBookieRackAffinityMapping.BOOKIE_INFO_ROOT_PATH);
             log.info("Updated rack mapping info for {}", bookieAddress);
         } else {
             // Creates the z-node with racks info