[inlong] branch master updated: [INLONG-7625][Manager] Make data encoding type as a common property of StreamSink (#7628)

[do...@apache.org]

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 4852c21d8 [INLONG-7625][Manager] Make data encoding type as a common property of StreamSink (#7628)
4852c21d8 is described below

commit 4852c21d8a3b47a9aac36a932891054d7871db55
Author: vernedeng <de...@pku.edu.cn>
AuthorDate: Thu Mar 16 16:26:56 2023 +0800

    [INLONG-7625][Manager] Make data encoding type as a common property of StreamSink (#7628)
---
 .../src/main/java/org/apache/inlong/manager/pojo/sink/StreamSink.java | 4 ++++
 .../main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSink.java  | 3 ---
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/StreamSink.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/StreamSink.java
index cbd6195a1..65aaf011c 100644
--- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/StreamSink.java
+++ b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/StreamSink.java
@@ -115,6 +115,10 @@ public abstract class StreamSink extends StreamNode {
     @ApiModelProperty("Properties for sink")
     private Map<String, Object> properties = Maps.newHashMap();
 
+    @Builder.Default
+    @ApiModelProperty("Encoding type for sink, default is UTF-8")
+    private String dataEncoding = "UTF-8";
+
     @JsonIgnore
     @Builder.Default
     @ApiModelProperty("Data format type for stream sink")
diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSink.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSink.java
index 63a410ae8..4fa4ff8a2 100644
--- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSink.java
+++ b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSink.java
@@ -74,9 +74,6 @@ public class HiveSink extends StreamSink {
     @ApiModelProperty("File format, support: TextFile, ORCFile, RCFile, SequenceFile, Avro, Parquet, etc")
     private String fileFormat;
 
-    @ApiModelProperty("Data encoding format: UTF-8, GBK")
-    private String dataEncoding;
-
     @ApiModelProperty("Data separator")
     private String dataSeparator;