?????? flinksql????doris??????

[41108453]

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"                            
                                                        
<lingm...@apache.org&gt;;
????????:&nbsp;2021??5??9??(??????) ????4:15
??????:&nbsp;"dev"<dev@doris.apache.org&gt;;

????:&nbsp;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_d...@foxmail.com <maker_d...@foxmail.com&gt; ??2021??5??8?????? 
????6:07??????

&gt; ????FlinkSQL??sql-client??????????????????????Doris??
&gt; Flink SQL&gt; CREATE TABLE flink_doris_source
&gt; &gt; (
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp; siteid INT,
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp; citycode INT,
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp; username STRING,
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp; pv INT
&gt; &gt; )
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp; WITH (
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 'connector' = 'doris',
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 'fenodes' = 'xxx:8030',
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 'table.identifier' = 
'example_db.table1',
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 'username' = 'root',
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 'password' = 'admin123',
&gt; &gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 'sink.batch.size' = '1'
&gt; &gt; );
&gt; ????????????
&gt; select * from flink_doris_source;
&gt;
&gt; ??????????????????????????????
&gt; ?????????????????????????? ??????????????????
&gt; [ERROR] Could not execute SQL
&gt; statement.Reason:java.lang.NoSuchMethodError:
&gt;
&gt; 
scala.collection.JavaConversions$.deprecated$u0020asScalaSet(Ljava/util/Set;)Lscala/collection/mutable/Set;
&gt;
&gt; doris-version:0.13 ????????????0.14??????????
&gt; flink-version:1.11.3
&gt; doris-flink-connector-version:1.0.0
&gt; ??????????????
&gt;
&gt;
&gt;
&gt; maker_d...@foxmail.com
&gt;