diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/handler/database/MetaDataChangedHandler.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/handler/database/MetaDataChangedHandler.java index 445f982bf42fd..26fe2103cb2b9 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/handler/database/MetaDataChangedHandler.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/handler/database/MetaDataChangedHandler.java @@ -51,22 +51,22 @@ public final class MetaDataChangedHandler { * @return handle completed or not */ public boolean handle(final String databaseName, final DataChangedEvent event) { - String key = event.getKey(); - Optional schemaName = DatabaseMetaDataNode.getSchemaName(key); + String eventKey = event.getKey(); + Optional schemaName = DatabaseMetaDataNode.getSchemaName(eventKey); if (schemaName.isPresent()) { handleSchemaChanged(databaseName, schemaName.get(), event.getType()); return true; } - schemaName = DatabaseMetaDataNode.getSchemaNameByTableNode(key); - if (schemaName.isPresent() && isTableMetaDataChanged(event.getKey())) { + schemaName = DatabaseMetaDataNode.getSchemaNameByTableNode(eventKey); + if (schemaName.isPresent() && isTableMetaDataChanged(eventKey)) { handleTableChanged(databaseName, schemaName.get(), event); return true; } - if (schemaName.isPresent() && isViewMetaDataChanged(event.getKey())) { + if (schemaName.isPresent() && isViewMetaDataChanged(eventKey)) { handleViewChanged(databaseName, schemaName.get(), event); return true; } - if (DataSourceMetaDataNode.isDataSourcesNode(key)) { + if (DataSourceMetaDataNode.isDataSourcesNode(eventKey)) { handleDataSourceChanged(databaseName, event); return true; }