?????? sql-client ??jdbc??????

[op]

???? ????????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<samyang31...@gmail.com&gt;;
????????:&nbsp;2020??7??27??(??????) ????5:47
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: sql-client ??jdbc??????



?? yarn ?????? job ???????????????? sql-client 
?????????????????????????????????????????? bin/flink,
bin/yarn-session.sh, conf/flink-conf.yaml ?????????? bin/sql-client.sh,
conf/sql-client-defaults.yaml ??????

???????????????????????????????????????????????????? sql-client.sh 
??????????????

op <520075...@qq.com&gt; ??2020??7??27?????? ????5:29??????

&gt; ??????
&gt; &amp;nbsp; 
????????????????????????????yarn??????????????,sql-client??????????????1.11.0????
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 "user-zh"
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 <
&gt; samyang31...@gmail.com&amp;gt;;
&gt; ????????:&amp;nbsp;2020??7??27??(??????) ????5:25
&gt; ??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: sql-client ??jdbc??????
&gt;
&gt;
&gt;
&gt; hi,
&gt;
&gt; ???????????? class path ???? mysql-connector-java-5.1.38.jar 
????????????????????????????????
&gt;
&gt; op <520075...@qq.com&amp;gt; ??2020??7??27?????? ????2:45??????
&gt;
&gt; &amp;gt; ??????????????????jdbc????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; CREATE TABLE mvp_dim_anticheat_args_all (
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; id BIGINT,
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; dt STRING,
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; cnt_7d INT,
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;cnt_30d INT,
&gt; &amp;gt; &amp;amp;nbsp; PRIMARY KEY (id) NOT ENFORCED
&gt; &amp;gt; ) WITH (
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;'connector' = 'jdbc',
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;'driver'='com.mysql.jdbc.Driver',
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;'url' = 
'jdbc:mysql://localhost:3306/huyou_oi',
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;'table-name' = 'mvp_dim_ll',
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;'username' = 'huy_oi',
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;'password' = '420123'
&gt; &amp;gt; );
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ????????????&amp;amp;nbsp;
&gt; &amp;gt; [ERROR] Could not execute SQL statement. Reason:
&gt; &amp;gt; java.lang.ClassNotFoundException: com.mysql.jdbc.Driver
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; 
????????????lib??????&amp;amp;nbsp;flink-connector-jdbc_2.11-1.11.0.jar
&gt; &amp;gt; ??&amp;amp;nbsp;mysql-connector-java-5.1.38.jar 
????????????????????????
&gt; &amp;gt; ????