Caused by: java.lang.ClassNotFoundException: org.apache.flink.cdc.connectors.mysql.source.MySqlSource

[mxd-1999]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

我在首次启动任务的时候，报了这个错误，那时任务根本无发提交。于是我把flink-sql-connector-mysql-cdc-3.1.1包加入了进来，流程可以继续往下走。当我把其他jar包缺失问题解决后，此时任务已经可以向flink提交，说明已经可以扫描到包了，但是又爆了这个相同的错误，这个jar包为什么在这一步找不到呢？

我看到资源管理里面这个包已经加载进来了

编译工具也能找到这个类

我原本以为他可能会找flink-connector-mysql-cdc，于是把这个也引进来了，错误仍然存在。求助！

What you expected to happen

我希望可以正常启动任务

How to reproduce

在1.1.0版本中，mysql整库同步到kafka案例

Anything else

No response

Version

1.1.0

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[github-actions]

Hello @mxd-1999, this issue is about CDC/CDCSOURCE, so I assign it to @aiwenmo. If you have any questions, you can comment and reply.

你好 @mxd-1999, 这个 issue 是关于 CDC/CDCSOURCE 的，所以我把它分配给了 @aiwenmo。如有任何问题，可以评论回复。