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 21643af02 [INLONG-4880][Manger] Modify the ClickHouse configuration to 
make the saved info consistent with the query (#4881)
21643af02 is described below

commit 21643af02284ac31dfba274c1dce042cb4935003
Author: Greedyu <[email protected]>
AuthorDate: Wed Jul 6 10:24:23 2022 +0800

    [INLONG-4880][Manger] Modify the ClickHouse configuration to make the saved 
info consistent with the query (#4881)
---
 .../inlong/manager/common/pojo/sink/ck/ClickHouseSink.java       | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/ck/ClickHouseSink.java
 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/ck/ClickHouseSink.java
index 5ecfc820e..f5118e37f 100644
--- 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/ck/ClickHouseSink.java
+++ 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/ck/ClickHouseSink.java
@@ -82,6 +82,15 @@ public class ClickHouseSink extends StreamSink {
     @ApiModelProperty("ClickHouse table engine")
     private String engine;
 
+    @ApiModelProperty("Table partition information")
+    private String partitionBy;
+
+    @ApiModelProperty("Table order information")
+    private String orderBy;
+
+    @ApiModelProperty("Table primary key")
+    private String primaryKey;
+
     public ClickHouseSink() {
         this.setSinkType(SinkType.SINK_CLICKHOUSE);
     }

Reply via email to