flink读取doris中通过catalog配置的表报错

Viewed 21

doris版本:2.1.15
flink版本:1.20.1
flink.connector.version版本:3.3.0-1.20
flink-doris-connector-1.20版本:25.1.0
启动flink读取doris中通过catalog配置的表时,报错argument 'Doris BE' is illegal, value is ''.
在建表语句中手动指定benodes也不行
CREATE TABLE DorisSourceTest (
id string,
name string
)
WITH (
'connector' = 'doris',
'fenodes' = '',
'benodes' = '',
'table.identifier' = 'hive.database.table',
'username' = '',
'password' = ''
)

1 Answers