DongTL opened a new issue #5771: URL: https://github.com/apache/incubator-doris/issues/5771
**Describe the bug** 使用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; ``` 希望大佬解答。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
