address comment

apache · Jul 26, 2024 · bf8b6a9 · bf8b6a9
1 parent 98d122e
commit bf8b6a9
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();
             }