@flink.apache.org
抄送： user-zh
主题： 回复： sql-cli执行sql报错
HI,
大致看了下，建议可以这么排查：
1 flink-connector-kafka* 包太多了，仅保留你需要的版本即可
2 kafka-clients*包版本太高了，你看看你需要的版本是哪个
Best, xingoo
28 10:22
> flink-connector-kafka-base_2.11-1.10.2.jar
> -rw-rw-r-- 1 test test106632 Aug 17 16:36
> flink-connector-kafka-base_2.12-1.10.2.jar
> -rw-rw-r-- 1 test test 1893564 Jul 24 2018 kafka-clients-2.0.0.jar
>
>
>
> hl9...@126.com
>
> 发件人： 111
> 发送时间： 20
HI,
大致看了下，建议可以这么排查：
1 flink-connector-kafka* 包太多了，仅保留你需要的版本即可
2 kafka-clients*包版本太高了，你看看你需要的版本是哪个
Best, xingoo
fka-clients-2.0.0.jar
hl9...@126.com
发件人： 111
发送时间： 2020-09-28 09:23
收件人： user-zh@flink.apache.org
主题： 回复：sql-cli执行sql报错
你貌似使用的是flink-1.11的语法。
可以修改成flink-1.10的语法试试，参考文档：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#kafka-connector
| |
xinghalo
|
|
xi
你貌似使用的是flink-1.11的语法。
可以修改成flink-1.10的语法试试，参考文档：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#kafka-connector
| |
xinghalo
|
|
xingh...@163.com
|
签名由网易邮箱大师定制
在2020年09月28日 09:16，hl9...@126.com 写道：
flink版本1.10.2,问题重现如下，请问各位大佬是什么原因：
./sql-client.sh embedded
