FlinkCDC 3.1.0 submitting the job, throws a error ：Cannot find factory with identifier "mysql" in the classpath

[davon-noidea]

command ： ./bin/flink-cdc.sh mutilpart-mysql-to-doris.yaml --jar lib/mysql-connector-java-8.0.27.jar
Using FlinkCDC version 3.0.1, the command starts the task successfully, but with FlinkCDC 3.1.0, it fails with the following error:

Exception in thread "main" java.lang.RuntimeException: Cannot find factory with identifier "mysql" in the classpath.
Available factory classes are:
at org.apache.flink.cdc.composer.utils.FactoryDiscoveryUtils.getFactoryByIdentifier(FactoryDiscoveryUtils.java:62)
at org.apache.flink.cdc.composer.flink.translator.DataSourceTranslator.translate(DataSourceTranslator.java:47)
at org.apache.flink.cdc.composer.flink.FlinkPipelineComposer.compose(FlinkPipelineComposer.java:101)
at org.apache.flink.cdc.cli.CliExecutor.run(CliExecutor.java:71)
at org.apache.flink.cdc.cli.CliFrontend.main(CliFrontend.java:71)

[yuxiqian]

Could you please check if you have placed MySQL pipeline connector with corresponding version (3.1.0) in CDC lib directory? Seems CLI failed to discover pipeline source factory during job startup.

[davon-noidea]

非常感谢你的回答，我的MySQL pipeline connector 是3.0.0的，是需要下载3.1.0的吗？但我没找到3.1.0的版本。

[yuxiqian]

Yes, 3.0 jars aren't compatible with 3.1+. It's an exception since we changed package names during the donation to ASF.

You may download 3.1.0 jars at GitHub releases page or Maven central repository with org.apache.flink group ID.

[davon-noidea]

好的，非常感谢你的解答！