address comment

apache · Jul 15, 2024 · 68143c4 · 68143c4
1 parent c4c37d0
commit 68143c4
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -498,7 +498,7 @@ protected void receivedSessionEvent(SessionEvent event) {
         isConnected = event.isConnected();
 
         // Clear cache after session expired.
-        if (event == SessionEvent.SessionLost) {
+        if (event == SessionEvent.SessionLost || event == SessionEvent.ConnectionLost) {
             for (MetadataCacheImpl metadataCache : metadataCaches) {
                 metadataCache.invalidateAll();
             }