doris通过catalog集成Hive后,flink再集成doris,如何查询这个Hive表

Viewed 68

doris通过catalog集成Hive后,可以直接在doris中查询Hive的表,如 select * from catalog.database.table;
flink集成doris后,可以查询doris中建的表

CREATE TABLE Student (
    id STRING,
    name STRING,
    age INT
    ) 
    WITH (
      'connector' = 'doris',
      'fenodes' = '127.0.0.1:8030',
      'table.identifier' = 'test.student',
      'username' = 'root',
      'password' = ''
);

但是查不了Hive的表,table.identifier写catalog.database.table就会报错
Caused by: org.apache.doris.flink.exception.IllegalArgumentException: argument 'table.identifier' is illegal, value is 'catalog.database.table'.
请问flink可以查询doris中的Hive表数据吗?

1 Answers