[inlong] branch master updated: [INLONG-6815][Manager] Elasticsearch port parameter is missing (#6817)

[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 dd2844562 [INLONG-6815][Manager] Elasticsearch port parameter is 
missing (#6817)
dd2844562 is described below

commit dd284456292441f7411a631464e93d01d27bfed8
Author: wangpeix <105137931+wangp...@users.noreply.github.com>
AuthorDate: Mon Dec 12 15:34:17 2022 +0800

    [INLONG-6815][Manager] Elasticsearch port parameter is missing (#6817)
    
    Co-authored-by: wangpeix <luckywang...@didiglobal.com>
---
 .../org/apache/inlong/manager/pojo/sink/es/ElasticsearchSinkDTO.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/es/ElasticsearchSinkDTO.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/es/ElasticsearchSinkDTO.java
index 2121f237a..3e62aa5b4 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/es/ElasticsearchSinkDTO.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/es/ElasticsearchSinkDTO.java
@@ -95,6 +95,7 @@ public class ElasticsearchSinkDTO {
         }
         return ElasticsearchSinkDTO.builder()
                 .host(request.getHost())
+                .port(request.getPort())
                 .username(request.getUsername())
                 .password(passwd)
                 .indexName(request.getIndexName())