flinkcdc mysql DataStream API 问题解析
根据描述的代码和问题，可能存在以下问题：
版本不匹配：
flink 的版本（1.15.1）与使用的 Flink CDC 声明的版本（2.1.1）不匹配。应该使用与 Flink CDC 相对应的 Flink 版本，即 1.13.6。
相关 JAR 包不对应：
除了驱动程序之外，Flink CDC 所依赖的 JAR 包的版本也需要与声明的版本一致。因此，应该将 IDE 中依赖的非 Flink JAR 包（例如阿里巴巴的 FastJSON）复制到 Flink 的 lib 目录（%FLINK_HOME%/lib）中，并确保版本与 Flink CDC 需要的版本相符。
修复以上问题后，代码才能正常运行。
以上就是Flink CDC MySQL DataStream API 问题：版本不匹配和 JAR 包依赖问题怎么解决？的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/45778.html
微信扫一扫 
支付宝扫一扫 
