AbstractMetadataStore: invalidate childrenCache correctly when node c…

…reated
datastax · Feb 8, 2022 · d5ce3a0 · d5ce3a0
1 parent 60d462a
commit d5ce3a0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
@@ -166,6 +166,7 @@ public void accept(Notification n) {
 
         if (type == NotificationType.Created || type == NotificationType.Deleted) {
             existsCache.synchronous().invalidate(path);
+            childrenCache.synchronous().invalidate(path);
             String parent = parent(path);
             if (parent != null) {
                 childrenCache.synchronous().invalidate(parent);