Re: [I] Flink Sql Mongo 使用的版本是2.1.1 执行同步mongo数据 ,控制台报错: java.lang.ClassCastException: com.ververica.cdc.connectors.mongodb.internal.MongoDBConnectorSourceConnector cannot be cast to com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.source.SourceConnector at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:668) [flink-sql-connector-mysql-cdc-2.1.1.jar:2.1.1] at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) [flink-sql-connector-mysql-cdc-2.1.1.jar:2.1.1] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_281] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_281] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_281] [flink-cdc]

[via GitHub]

QuintinLuke commented on issue #797:
URL: https://github.com/apache/flink-cdc/issues/797#issuecomment-2317005221

   > 问题找到了,依赖中有flink cdc mysql所以才会报错
   
   不能有其他的cdc?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org