使用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