(shardingsphere) branch master updated: Refactor CoordinatorRegistryCenterInitializer (#33288)

[zh...@apache.org]

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

zhangliang 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 6a931e1b428 Refactor CoordinatorRegistryCenterInitializer (#33288)
6a931e1b428 is described below

commit 6a931e1b428b2aee7344fa090eb398433408eceb
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Thu Oct 17 21:27:01 2024 +0800

    Refactor CoordinatorRegistryCenterInitializer (#33288)
---
 .../registrycenter/elasticjob/CoordinatorRegistryCenterInitializer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/registrycenter/elasticjob/CoordinatorRegistryCenterInitializer.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/registrycenter/elasticjob/CoordinatorRegistryCenterInitializer.java
index 038df611539..92b8c584fb2 100644
--- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/registrycenter/elasticjob/CoordinatorRegistryCenterInitializer.java
+++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/registrycenter/elasticjob/CoordinatorRegistryCenterInitializer.java
@@ -51,7 +51,7 @@ public final class CoordinatorRegistryCenterInitializer {
         // TODO Merge registry center code in ElasticJob and ShardingSphere mode; Use SPI to load impl
         Properties props = repositoryConfig.getProps();
         ZookeeperProperties zookeeperProps = new ZookeeperProperties(props);
-        String namespace = repositoryConfig.getNamespace() + (null != namespaceRelativePath ? namespaceRelativePath : "");
+        String namespace = repositoryConfig.getNamespace() + (null == namespaceRelativePath ? "" : namespaceRelativePath);
         ZookeeperConfiguration result = new ZookeeperConfiguration(repositoryConfig.getServerLists(), namespace);
         int retryIntervalMilliseconds = zookeeperProps.getValue(ZookeeperPropertyKey.RETRY_INTERVAL_MILLISECONDS);
         result.setBaseSleepTimeMilliseconds(retryIntervalMilliseconds);