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);
}