Flink CDC中我遇到了问题，我用pyflink，想mysql-cdc但是一直报错。知道原因吗？

你是用SQL bound的jar包吗，重启集群了吗，用的flink-connector-mysql-cdc-2.3.0.jar，flink-sql-connector-mysql-cdc-2.3.0.jar，你得用这个，找找他们有什么不同，除了flink cdc的开发人员，没有人需求是那那个不带SQL的JAR包，flink 开发有两个代码方式，一个是datastream，一个是tabl api ，各有各的不同，分场景使用，用不带SQL的jar包，就等着依赖风暴吧，搞死你也解不出来 https://github.com/ververica/flink-cdc-connectors/issues/1729%20%20%E8%BF%99%E4%B8%AA%20issue%20%E4%BC%9A%E6%8F%90%E4%BE%9B%E6%8C%87%E5%8D%97，找找你们得dba may be ，所以你可以发一下你的pom和ds代码看一下，此回答整理自钉群“Flink CDC 社区”