You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/05/01 09:53:14 UTC

[incubator-doris] branch master updated: [doc] Add Flink Connector Sink Bitmap Type Doc (#9316)

This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git


The following commit(s) were added to refs/heads/master by this push:
     new bdf66731fa [doc] Add Flink Connector Sink Bitmap Type Doc (#9316)
bdf66731fa is described below

commit bdf66731fa075809bca61e229fb45be676cbb803
Author: wudi <67...@qq.com>
AuthorDate: Sun May 1 17:53:10 2022 +0800

    [doc] Add Flink Connector Sink Bitmap Type Doc (#9316)
---
 docs/en/ecosystem/flink-doris-connector.md    | 19 ++++++++++++++++++-
 docs/zh-CN/ecosystem/flink-doris-connector.md | 19 ++++++++++++++++++-
 2 files changed, 36 insertions(+), 2 deletions(-)

diff --git a/docs/en/ecosystem/flink-doris-connector.md b/docs/en/ecosystem/flink-doris-connector.md
index 096f6bb5ba..23623f386b 100644
--- a/docs/en/ecosystem/flink-doris-connector.md
+++ b/docs/en/ecosystem/flink-doris-connector.md
@@ -443,6 +443,23 @@ Then suppose a row of data is 500B, and the user wants every 100MB or 10 seconds
 
 ### common problem
 
-1.Could not execute SQL statement. Reason:java.lang.IllegalAraumenException: Row parity: 32,but serializer rarity:31
+1. Could not execute SQL statement. Reason:java.lang.IllegalAraumenException: Row parity: 32,but serializer rarity:31
 
 Because Doris has a hidden column, you need to manually add a column `__DORIS_DELETE_SIGN__` in Flink Schema Type: TINYINT
+
+2. Bitmap type write
+```sql
+CREATE TABLE bitmap_sink (
+dt int,
+page string,
+user_id int
+)
+WITH (
+   'connector' = 'doris',
+   'fenodes' = '127.0.0.1:8030',
+   'table.identifier' = 'test.bitmap_test',
+   'username' = 'root',
+   'password' = '',
+   'sink.properties.columns' = 'dt,page,user_id,user_id=to_bitmap(user_id)'
+)
+````
diff --git a/docs/zh-CN/ecosystem/flink-doris-connector.md b/docs/zh-CN/ecosystem/flink-doris-connector.md
index 9832d9c026..bab1901ae2 100644
--- a/docs/zh-CN/ecosystem/flink-doris-connector.md
+++ b/docs/zh-CN/ecosystem/flink-doris-connector.md
@@ -522,6 +522,23 @@ Flink Doris Connector写入频率主要是通过sink.batch.size,sink.batch.int
 
 ### 常见问题
 
-1.Could not execute SQL statement. Reason:java.lang.IllegalAraumenException: Row parity: 32,but serializer rarity:31
+1. Could not execute SQL statement. Reason:java.lang.IllegalAraumenException: Row parity: 32,but serializer rarity:31
 
 因为Doris有个隐藏列,需要在Flink Schema中手动添加一列`__DORIS_DELETE_SIGN__`  类型:TINYINT
+
+2. Bitmap类型写入
+```sql
+CREATE TABLE bitmap_sink (
+dt int,
+page string,
+user_id int 
+)
+WITH (
+  'connector' = 'doris',
+  'fenodes' = '127.0.0.1:8030',
+  'table.identifier' = 'test.bitmap_test',
+  'username' = 'root',
+  'password' = '',
+  'sink.properties.columns' = 'dt,page,user_id,user_id=to_bitmap(user_id)'
+)
+```


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org