This is an automated email from the ASF dual-hosted git repository.

jianglongtao pushed a commit to branch fix-33341
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git

commit 31b3b4c4e97a32bbb09745a71721affa0e6bcb23
Author: zhaojinchao <[email protected]>
AuthorDate: Mon Aug 12 14:08:29 2024 +0800

    Refactor ListenerAssistedSubscriber
---
 .../cluster/coordinator/subscriber/ListenerAssistedSubscriber.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/ListenerAssistedSubscriber.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/ListenerAssistedSubscriber.java
index 313955480c2..a639b525d66 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/ListenerAssistedSubscriber.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/ListenerAssistedSubscriber.java
@@ -64,7 +64,7 @@ public final class ListenerAssistedSubscriber {
     @Subscribe
     public synchronized void renew(final DropDatabaseListenerAssistedEvent 
event) {
         
listenerManager.removeListener(DatabaseMetaDataNode.getDatabaseNamePath(event.getDatabaseName()));
-        
contextManager.getMetaDataContexts().getMetaData().dropDatabase(event.getDatabaseName());
+        
contextManager.getResourceMetaDataContextManager().dropDatabase(event.getDatabaseName());
         
contextManager.getMetaDataContexts().getPersistService().getListenerAssistedPersistService().deleteDatabaseNameListenerAssisted(event.getDatabaseName());
     }
 }

Reply via email to