[inlong] branch master updated: [INLONG-8944][Manager] Fix the issue of not setting encryptVersion (#8945)

[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 c817e5a56c [INLONG-8944][Manager] Fix the issue of not setting 
encryptVersion (#8945)
c817e5a56c is described below

commit c817e5a56c8eaa9b2bcf5e3834948419d6ac6d24
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Wed Sep 20 18:25:19 2023 +0800

    [INLONG-8944][Manager] Fix the issue of not setting encryptVersion (#8945)
---
 .../java/org/apache/inlong/manager/pojo/sink/ck/ClickHouseSinkDTO.java   | 1 +
 .../java/org/apache/inlong/manager/pojo/sink/doris/DorisSinkDTO.java     | 1 +
 .../main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSinkDTO.java  | 1 +
 .../apache/inlong/manager/pojo/sink/postgresql/PostgreSQLSinkDTO.java    | 1 +
 .../org/apache/inlong/manager/pojo/sink/starrocks/StarRocksSinkDTO.java  | 1 +
 5 files changed, 5 insertions(+)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/ck/ClickHouseSinkDTO.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/ck/ClickHouseSinkDTO.java
index 3f2fad189a..a8bb34a33f 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/ck/ClickHouseSinkDTO.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/ck/ClickHouseSinkDTO.java
@@ -125,6 +125,7 @@ public class ClickHouseSinkDTO {
                 : new ClickHouseSinkDTO();
         CommonBeanUtils.copyProperties(request, dto, true);
         dto.setPassword(passwd);
+        dto.setEncryptVersion(encryptVersion);
         return dto;
     }
 
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/doris/DorisSinkDTO.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/doris/DorisSinkDTO.java
index 4ed330c489..ecbd38c042 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/doris/DorisSinkDTO.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/doris/DorisSinkDTO.java
@@ -95,6 +95,7 @@ public class DorisSinkDTO {
         DorisSinkDTO dto = StringUtils.isNotBlank(extParams) ? 
DorisSinkDTO.getFromJson(extParams) : new DorisSinkDTO();
         CommonBeanUtils.copyProperties(request, dto, true);
         dto.setPassword(passwd);
+        dto.setEncryptVersion(encryptVersion);
         return dto;
     }
 
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSinkDTO.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSinkDTO.java
index bfe701eaf8..2dfe6f0b11 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSinkDTO.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSinkDTO.java
@@ -108,6 +108,7 @@ public class HiveSinkDTO {
         HiveSinkDTO dto = StringUtils.isNotBlank(extParams) ? 
HiveSinkDTO.getFromJson(extParams) : new HiveSinkDTO();
         CommonBeanUtils.copyProperties(request, dto, true);
         dto.setPassword(passwd);
+        dto.setEncryptVersion(encryptVersion);
         return dto;
     }
 
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/postgresql/PostgreSQLSinkDTO.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/postgresql/PostgreSQLSinkDTO.java
index 67fa485cfc..46b64a0e8c 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/postgresql/PostgreSQLSinkDTO.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/postgresql/PostgreSQLSinkDTO.java
@@ -85,6 +85,7 @@ public class PostgreSQLSinkDTO {
                 : new PostgreSQLSinkDTO();
         CommonBeanUtils.copyProperties(request, dto, true);
         dto.setPassword(passwd);
+        dto.setEncryptVersion(encryptVersion);
         return dto;
     }
 
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/starrocks/StarRocksSinkDTO.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/starrocks/StarRocksSinkDTO.java
index f9a64e2c5e..c4ce365036 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/starrocks/StarRocksSinkDTO.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/starrocks/StarRocksSinkDTO.java
@@ -109,6 +109,7 @@ public class StarRocksSinkDTO {
                 ? StarRocksSinkDTO.getFromJson(extParams)
                 : new StarRocksSinkDTO();
         CommonBeanUtils.copyProperties(request, dto, true);
+        dto.setEncryptVersion(encryptVersion);
         dto.setPassword(passwd);
         return dto;
     }