Question in English: Using Doris Flink connector If the table is empty, the program will stop after a few seconds of query. If there is data in the table and the data cannot be queried, an error will be reported after a few seconds of query: [ERROR] Could not execute SQL statement.Reason:java.lang.NoSuchMethodError: scala.collection.JavaConversions$.deprecated$u0020asScalaSet(Ljava/util/Set;)Lscala/collection/mutable/Set;
@JiaFeng, Zhang Ling Miao maker_d...@foxmail.com <maker_d...@foxmail.com> 于2021年5月8日周六 下午6:07写道： > 使用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 >
