diff --git a/server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java b/server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java
index 1ea664dc8..23ad94a24 100644
--- a/server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java
+++ b/server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java
@@ -163,6 +163,8 @@ public boolean deleteByConnectId(String connectId) {
                     }
                 }
             }
+            //force remove connectId
+            invalidateConnectIndex(connectId);
             return true;
         } catch (Exception e) {
             LOGGER.error("Delete subscriber by connectId {} error!", connectId, e);