Re: sql-client 的jdbc表出错

Mon, 27 Jul 2020 02:48:23 -0700 

在 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> 于2020年7月27日周一 下午5:29写道：

> 你好，
> &nbsp; 很确定，检查了好几遍，提交到yarn上执行都没问题,sql-client里面报这个错，1.11.0版本
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "user-zh"
>                                                                     <
> samyang31...@gmail.com&gt;;
> 发送时间:&nbsp;2020年7月27日(星期一) 下午5:25
> 收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
>
> 主题:&nbsp;Re: sql-client 的jdbc表出错
>
>
>
> hi,
>
> 你能确定你的 class path 下有 mysql-connector-java-5.1.38.jar 依赖吗？请在运行时确认下这一点。
>
> op <520075...@qq.com&gt; 于2020年7月27日周一 下午2:45写道：
>
> &gt; 您好，我创建了一个jdbc的表
> &gt;
> &gt;
> &gt; CREATE TABLE mvp_dim_anticheat_args_all (
> &gt; &amp;nbsp; &amp;nbsp; id BIGINT,
> &gt; &amp;nbsp; &amp;nbsp; dt STRING,
> &gt; &amp;nbsp; &amp;nbsp; cnt_7d INT,
> &gt; &amp;nbsp; &amp;nbsp;cnt_30d INT,
> &gt; &amp;nbsp; PRIMARY KEY (id) NOT ENFORCED
> &gt; ) WITH (
> &gt; &amp;nbsp; &amp;nbsp;'connector' = 'jdbc',
> &gt; &amp;nbsp; &amp;nbsp;'driver'='com.mysql.jdbc.Driver',
> &gt; &amp;nbsp; &amp;nbsp;'url' = 'jdbc:mysql://localhost:3306/huyou_oi',
> &gt; &amp;nbsp; &amp;nbsp;'table-name' = 'mvp_dim_ll',
> &gt; &amp;nbsp; &amp;nbsp;'username' = 'huy_oi',
> &gt; &amp;nbsp; &amp;nbsp;'password' = '420123'
> &gt; );
> &gt;
> &gt;
> &gt;
> &gt; 查询的时候报&amp;nbsp;
> &gt; [ERROR] Could not execute SQL statement. Reason:
> &gt; java.lang.ClassNotFoundException: com.mysql.jdbc.Driver
> &gt;
> &gt;
> &gt;
> &gt;
> &gt;
> &gt; 我的安装目录lib下面有&amp;nbsp;flink-connector-jdbc_2.11-1.11.0.jar
> &gt; 和&amp;nbsp;mysql-connector-java-5.1.38.jar 这俩，请问是什么原因？？
> &gt; 谢谢

回复