You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@doris.apache.org by "maker_dong@foxmail.com" <ma...@foxmail.com> on 2021/05/08 10:07:03 UTC
flinksql查询doris表报错
使用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_dong@foxmail.com
回复： flinksql查询doris表报错
Posted by 41108453 <41...@qq.com>.
The flink connector is developed based on Scala 2.12.x, because the APIs between major Scala versions are not compatible, so please use Scala 2.12.x to compile flink connector
------------------ 原始邮件 ------------------
发件人: "dev" <lingmiao@apache.org>;
发送时间: 2021年5月9日(星期天) 下午4:15
收件人: "dev"<dev@doris.apache.org>;
主题: Re: flinksql查询doris表报错
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_dong@foxmail.com <maker_dong@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_dong@foxmail.com
>
Re: flinksql查询doris表报错
Posted by ling miao <li...@apache.org>.
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_dong@foxmail.com <ma...@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_dong@foxmail.com
>