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

sunnianjun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 7d2e983991f Code format for MetaDataChangedSubscriber (#32704)
7d2e983991f is described below

commit 7d2e983991f48b2158edf51c24254041a6374938
Author: Liang Zhang <[email protected]>
AuthorDate: Tue Aug 27 19:08:57 2024 +0800

    Code format for MetaDataChangedSubscriber (#32704)
---
 .../cluster/event/subscriber/dispatch/MetaDataChangedSubscriber.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/MetaDataChangedSubscriber.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/MetaDataChangedSubscriber.java
index 0c23fd7005f..10a93688bfa 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/MetaDataChangedSubscriber.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/dispatch/MetaDataChangedSubscriber.java
@@ -80,8 +80,7 @@ public final class MetaDataChangedSubscriber implements 
EventSubscriber {
                 .getActiveVersionByFullPath(event.getActiveVersionKey())), 
"Invalid active version: %s of key: %s", event.getActiveVersion(), 
event.getActiveVersionKey());
         Map<String, ShardingSphereTable> tables = 
contextManager.getPersistServiceFacade().getMetaDataPersistService().getDatabaseMetaDataService()
                 
.getTableMetaDataPersistService().load(event.getDatabaseName(), 
event.getSchemaName(), event.getTableName());
-        
contextManager.getMetaDataContextManager().getSchemaMetaDataManager().alterSchema(event.getDatabaseName(),
 event.getSchemaName(),
-                tables.values().iterator().next(), null);
+        
contextManager.getMetaDataContextManager().getSchemaMetaDataManager().alterSchema(event.getDatabaseName(),
 event.getSchemaName(), tables.values().iterator().next(), null);
         refreshShardingSphereStatisticsData();
     }
     

Reply via email to