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()); } }
