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 <[email protected]>
AuthorDate: Mon Dec 12 15:34:17 2022 +0800
[INLONG-6815][Manager] Elasticsearch port parameter is missing (#6817)
Co-authored-by: wangpeix <[email protected]>
---
.../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())
