From 8945a3c353573f26fb5c73b26302f60ab672ebec Mon Sep 17 00:00:00 2001 From: Goson Zhang <4675739@qq.com> Date: Fri, 3 Jan 2025 17:24:24 +0800 Subject: [PATCH] [INLONG-11632][SDK] The manager address was mistakenly truncated (#11633) Co-authored-by: gosonzhang --- .../org/apache/inlong/sdk/dataproxy/ProxyClientConfig.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/ProxyClientConfig.java b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/ProxyClientConfig.java index 6a80fbf21c..1d03ee5b3a 100644 --- a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/ProxyClientConfig.java +++ b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/ProxyClientConfig.java @@ -528,9 +528,9 @@ private void checkAndParseAddress(String managerAddress) throws ProxysdkExceptio String hostPortInfo; if (managerAddress.startsWith(ConfigConstants.HTTPS)) { this.visitManagerByHttp = false; - hostPortInfo = managerAddress.substring(ConfigConstants.HTTPS.length() + 1); + hostPortInfo = managerAddress.substring(ConfigConstants.HTTPS.length()); } else { - hostPortInfo = managerAddress.substring(ConfigConstants.HTTP.length() + 1); + hostPortInfo = managerAddress.substring(ConfigConstants.HTTP.length()); } if (StringUtils.isBlank(hostPortInfo)) { throw new ProxysdkException("managerAddress must include host:port info!");