Apache Flink 中文用户邮件列表

sql-client 的jdbc表出错

Classic

List

Threaded

6 messages Options

sql-client 的jdbc表出错

您好，我创建了一个jdbc的表

CREATE TABLE mvp_dim_anticheat_args_all (
    id BIGINT,
    dt STRING,
    cnt_7d INT,
   cnt_30d INT,
  PRIMARY KEY (id) NOT ENFORCED
) WITH (
   'connector' = 'jdbc',
   'driver'='com.mysql.jdbc.Driver',
   'url' = 'jdbc:mysql://localhost:3306/huyou_oi',
   'table-name' = 'mvp_dim_ll',
   'username' = 'huy_oi',
   'password' = '420123'
);

查询的时候报 
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: com.mysql.jdbc.Driver

我的安装目录lib下面有 flink-connector-jdbc_2.11-1.11.0.jar 和 mysql-connector-java-5.1.38.jar 这俩，请问是什么原因？？
谢谢

Caizhi Weng

Re: sql-client 的jdbc表出错

Hi，

mysql-connector-java-5.1.38.jar 应该已经包含了 com.mysql.jdbc.Driver 才对；Flink
是以什么模式运行的呢？如果是 standalone session，在 Flink 的 lib 下添加 jar 包之后是否重启过 session
集群呢？另外是否所有的 worker 都添加了 jar 包呢？如果能打出完整的错误栈会更好。

op <[hidden email]> 于2020年7月27日周一下午2:45写道：

> 您好，我创建了一个jdbc的表
>
>
> CREATE TABLE mvp_dim_anticheat_args_all (
>     id BIGINT,
>     dt STRING,
>     cnt_7d INT,
>    cnt_30d INT,
>   PRIMARY KEY (id) NOT ENFORCED
> ) WITH (
>    'connector' = 'jdbc',
>    'driver'='com.mysql.jdbc.Driver',
>    'url' = 'jdbc:mysql://localhost:3306/huyou_oi',
>    'table-name' = 'mvp_dim_ll',
>    'username' = 'huy_oi',
>    'password' = '420123'
> );
>
>
>
> 查询的时候报 
> [ERROR] Could not execute SQL statement. Reason:
> java.lang.ClassNotFoundException: com.mysql.jdbc.Driver
>
>
>
>
>
> 我的安装目录lib下面有 flink-connector-jdbc_2.11-1.11.0.jar
> 和 mysql-connector-java-5.1.38.jar 这俩，请问是什么原因？？
> 谢谢

杨荣

Re: sql-client 的jdbc表出错

In reply to this post by op

hi,

你能确定你的 class path 下有 mysql-connector-java-5.1.38.jar 依赖吗？请在运行时确认下这一点。

op <[hidden email]> 于2020年7月27日周一下午2:45写道：

回复： sql-client 的jdbc表出错

你好，
  很确定，检查了好几遍，提交到yarn上执行都没问题,sql-client里面报这个错，1.11.0版本
------------------ 原始邮件 ------------------
发件人: "user-zh" <[hidden email]>;
发送时间: 2020年7月27日(星期一) 下午5:25
收件人: "user-zh"<[hidden email]>;

主题: Re: sql-client 的jdbc表出错

hi,

你能确定你的 class path 下有 mysql-connector-java-5.1.38.jar 依赖吗？请在运行时确认下这一点。

op <[hidden email]> 于2020年7月27日周一下午2:45写道：

> 您好，我创建了一个jdbc的表
>
>
> CREATE TABLE mvp_dim_anticheat_args_all (
> &nbsp; &nbsp; id BIGINT,
> &nbsp; &nbsp; dt STRING,
> &nbsp; &nbsp; cnt_7d INT,
> &nbsp; &nbsp;cnt_30d INT,
> &nbsp; PRIMARY KEY (id) NOT ENFORCED
> ) WITH (
> &nbsp; &nbsp;'connector' = 'jdbc',
> &nbsp; &nbsp;'driver'='com.mysql.jdbc.Driver',
> &nbsp; &nbsp;'url' = 'jdbc:mysql://localhost:3306/huyou_oi',
> &nbsp; &nbsp;'table-name' = 'mvp_dim_ll',
> &nbsp; &nbsp;'username' = 'huy_oi',
> &nbsp; &nbsp;'password' = '420123'
> );
>
>
>
> 查询的时候报&nbsp;
> [ERROR] Could not execute SQL statement. Reason:
> java.lang.ClassNotFoundException: com.mysql.jdbc.Driver
>
>
>
>
>
> 我的安装目录lib下面有&nbsp;flink-connector-jdbc_2.11-1.11.0.jar
> 和&nbsp;mysql-connector-java-5.1.38.jar 这俩，请问是什么原因？？
> 谢谢

杨荣

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

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

回复： sql-client 的jdbc表出错

谢谢我检查下

------------------ 原始邮件 ------------------
发件人: "user-zh" <[hidden email]>;
发送时间: 2020年7月27日(星期一) 下午5:47
收件人: "user-zh"<[hidden email]>;

主题: 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 <[hidden email]> 于2020年7月27日周一下午5:29写道：

> 你好，
> &nbsp; 很确定，检查了好几遍，提交到yarn上执行都没问题,sql-client里面报这个错，1.11.0版本
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "user-zh"
>                                                                     <
> [hidden email]&gt;;
> 发送时间:&nbsp;2020年7月27日(星期一) 下午5:25
> 收件人:&nbsp;"user-zh"<[hidden email]&gt;;
>
> 主题:&nbsp;Re: sql-client 的jdbc表出错
>
>
>
> hi,
>
> 你能确定你的 class path 下有 mysql-connector-java-5.1.38.jar 依赖吗？请在运行时确认下这一点。
>
> op <[hidden email]&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; 谢谢