invalidate children cache after key deleted apache#13487 apache#14779

Shawyeok · May 20, 2023 · d5e933c · d5e933c
1 parent 1e664b7
commit d5e933c
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
@@ -385,6 +385,7 @@ private CompletableFuture<Void> deleteInternal(String path, Optional<Long> expec
         // Ensure caches are invalidated before the operation is confirmed
         return storeDelete(path, expectedVersion).thenRun(() -> {
             existsCache.synchronous().invalidate(path);
+            childrenCache.synchronous().invalidate(path);
             String parent = parent(path);
             if (parent != null) {
                 childrenCache.synchronous().invalidate(parent);