Refactor ClusterMetaDataManagerPersistService (#34993)

terrymanu · web-flow · commit 88010aafcc49 · 2025-03-14T15:57:30.000+08:00
diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java
@@ -276,7 +276,7 @@ public void alterProperties(final Properties props) {
     private MetaDataContexts getReloadMetaDataContexts(final MetaDataContexts originalMetaDataContexts) {
         Thread.sleep(3000L);
         MetaDataContexts reloadMetaDataContexts = metaDataContextManager.getMetaDataContexts();
-        if (reloadMetaDataContexts.getMetaData() != originalMetaDataContexts.getMetaData() && reloadMetaDataContexts.getStatistics() != reloadMetaDataContexts.getStatistics()) {
+        if (reloadMetaDataContexts.getMetaData() != originalMetaDataContexts.getMetaData() && reloadMetaDataContexts.getStatistics() != originalMetaDataContexts.getStatistics()) {
             return reloadMetaDataContexts;
         }
         long startTime = System.currentTimeMillis();

Original file line number	Diff line number	Diff line change
`@@ -276,7 +276,7 @@ public void alterProperties(final Properties props) {`
`276`	`276`	`private MetaDataContexts getReloadMetaDataContexts(final MetaDataContexts originalMetaDataContexts) {`
`277`	`277`	`Thread.sleep(3000L);`
`278`	`278`	`MetaDataContexts reloadMetaDataContexts = metaDataContextManager.getMetaDataContexts();`
`279`		`- if (reloadMetaDataContexts.getMetaData() != originalMetaDataContexts.getMetaData() && reloadMetaDataContexts.getStatistics() != reloadMetaDataContexts.getStatistics()) {`
	`279`	`+ if (reloadMetaDataContexts.getMetaData() != originalMetaDataContexts.getMetaData() && reloadMetaDataContexts.getStatistics() != originalMetaDataContexts.getStatistics()) {`
`280`	`280`	`return reloadMetaDataContexts;`
`281`	`281`	`}`
`282`	`282`	`long startTime = System.currentTimeMillis();`