使用FlinkSQL的sql-client客户端,创建一张表连接Doris:
Flink SQL> CREATE TABLE flink_doris_source
> (
>     siteid INT,
>     citycode INT,
>     username STRING,
>     pv INT
> )
>     WITH (
>       'connector' = 'doris',
>       'fenodes' = 'xxx:8030',
>       'table.identifier' = 'example_db.table1',
>       'username' = 'root',
>       'password' = 'admin123',
>       'sink.batch.size' = '1'
> );
然后执行查询
select * from flink_doris_source;

若表是空的则查询数秒后程序停止
若表中有数据,数据查询不到 ,查询数秒后报错:
[ERROR] Could not execute SQL statement.Reason:java.lang.NoSuchMethodError: 
scala.collection.JavaConversions$.deprecated$u0020asScalaSet(Ljava/util/Set;)Lscala/collection/mutable/Set;

doris-version:0.13 也尝试编译了0.14,同样报错
flink-version:1.11.3
doris-flink-connector-version:1.0.0
希望大佬解答。



maker_d...@foxmail.com

Reply via email to