[inlong] branch master updated: [INLONG-6806][Manager] Fix the hosts incorrect parameter of es connector delivered by the manager (#6807)

[dockerzhang]

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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new fa00407e6 [INLONG-6806][Manager] Fix the hosts incorrect parameter of 
es connector delivered by the manager (#6807)
fa00407e6 is described below

commit fa00407e6b069da715a2a372c33e3e16e4cee0eb
Author: chestnufang <65438734+chestnu...@users.noreply.github.com>
AuthorDate: Fri Dec 9 11:33:01 2022 +0800

    [INLONG-6806][Manager] Fix the hosts incorrect parameter of es connector 
delivered by the manager (#6807)
    
    Co-authored-by: chestnufang <chestnuf...@tencent.com>
---
 .../java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java
index 24686c3b4..3e5322582 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/LoadNodeUtils.java
@@ -429,6 +429,8 @@ public class LoadNodeUtils {
      */
     public static ElasticsearchLoadNode createLoadNode(ElasticsearchSink 
elasticsearchSink,
             List<FieldInfo> fieldInfos, List<FieldRelation> fieldRelations, 
Map<String, String> properties) {
+        String host = elasticsearchSink.getHost();
+        Integer port = elasticsearchSink.getPort();
         return new ElasticsearchLoadNode(
                 elasticsearchSink.getSinkName(),
                 elasticsearchSink.getSinkName(),
@@ -439,7 +441,7 @@ public class LoadNodeUtils {
                 null,
                 properties,
                 elasticsearchSink.getIndexName(),
-                elasticsearchSink.getHost(),
+                String.format("http://%s:%d";, host, port),
                 elasticsearchSink.getUsername(),
                 elasticsearchSink.getPassword(),
                 elasticsearchSink.getDocumentType(),