[shardingsphere] branch master updated: Revise #16009 (#16027)

[panjuan]

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

panjuan 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 ebe5401  Revise #16009 (#16027)
ebe5401 is described below

commit ebe5401380d8d15e64a17eca31eca49bf8fd8ec8
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sun Mar 13 12:56:13 2022 +0800

    Revise #16009 (#16027)
---
 .../mode/metadata/persist/MetaDataPersistService.java         | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git 
a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/MetaDataPersistService.java
 
b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/MetaDataPersistService.java
index 62c73a8..30b748d 100644
--- 
a/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/MetaDataPersistService.java
+++ 
b/shardingsphere-mode/shardingsphere-mode-core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/MetaDataPersistService.java
@@ -153,12 +153,11 @@ public final class MetaDataPersistService {
      * @param isOverwrite whether overwrite registry center's configuration if 
existed
      */
     public void persistTransactionRule(final Properties props, final boolean 
isOverwrite) {
-        Collection<RuleConfiguration> ruleConfigurations = 
globalRuleService.load();
-        Optional<RuleConfiguration> ruleConfiguration = 
ruleConfigurations.stream().filter(each -> each instanceof 
TransactionRuleConfiguration).findFirst();
-        Preconditions.checkState(ruleConfiguration.isPresent());
-        if (props.equals(((TransactionRuleConfiguration) 
ruleConfiguration.get()).getProps())) {
-            return;
+        Collection<RuleConfiguration> ruleConfigs = globalRuleService.load();
+        Optional<RuleConfiguration> ruleConfig = 
ruleConfigs.stream().filter(each -> each instanceof 
TransactionRuleConfiguration).findFirst();
+        Preconditions.checkState(ruleConfig.isPresent());
+        if (!props.equals(((TransactionRuleConfiguration) 
ruleConfig.get()).getProps())) {
+            globalRuleService.persist(ruleConfigs, isOverwrite);
         }
-        globalRuleService.persist(ruleConfigurations, isOverwrite);
     }
 }