sink.properties.columns config issue #45615
Unanswered
ChenShuai1981
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
flink doris connector 什么情况需要用到 'sink.properties.columns' 配置参数?在flink sql中不是有定义sink doris的table列么,为什么还需要再在这个参数中申明需要插入哪些字段呢?即使是在部分列更新场景也可以从flink sql table中获取字段名呀,例如:
CREATE TABLE flink_doris_sink (
name STRING,
age INT,
price DECIMAL(5,2),
sale DOUBLE
)
WITH (
'connector' = 'doris',
'fenodes' = 'FE_IP:HTTP_PORT',
'table.identifier' = 'db.table',
'username' = 'root',
'password' = 'password',
'sink.label-prefix' = 'doris_label',
'sink.properties.partial_columns' = 'true',
‘sink.properties.columns’=‘name,age,price,sale’
);
Beta Was this translation helpful? Give feedback.
All reactions