flink sql client 连接mysql报错异常，如何解决？

Question

flink sql client 连接mysql
报错异常：
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat

Answer 1

可以试试这篇文章

flink入门2-flink连接mysql完成读写操作_sum墨的博客-CSDN博客_flink连接mysql 本文将会实现flink连接MySQL，废话不多说，上代码。本文章中的数据库表名为token，只有两个字段code和state2、读取数据源3、更新和写入数据4、启动类5、source、sink介绍sourcesink https://blog.csdn.net/weixin_33005117/article/details/125161432?spm=1001.2014.3001.5502