在Flink我配置的这种,报错了,怎么解决? -[阿里云_云淘科技]

在Flink我配置的这种,报错了,怎么解决?在Flink我配置的这种,报错了,怎么解决? -[阿里云_云淘科技]
Exception in thread “main” java.lang.RuntimeException: Cannot find factory with identifier “mysql” in the classpath.

Available factory classes are:

com.ververica.cdc.connectors.mysql.factory.MySqlDataSourceFactory
at com.ververica.cdc.composer.utils.FactoryDiscoveryUtils.getFactoryByIdentifier(FactoryDiscoveryUtils.java:60)
at com.ververica.cdc.composer.flink.FlinkPipelineComposer.createDataSink(FlinkPipelineComposer.java:144)
at com.ververica.cdc.composer.flink.FlinkPipelineComposer.compose(FlinkPipelineComposer.java:108)
at com.ververica.cdc.cli.CliExecutor.run(CliExecutor.java:65)
at com.ververica.cdc.cli.CliFrontend.main(CliFrontend.java:62)

本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/17716.html

(0)
匿名
上一篇 2023年12月28日 下午4:59
下一篇 2023年12月28日

相关推荐

新手站长从“心”出发,感谢16年您始终不离不弃。