Wink
Wink
Dinky 中 1.13 的整库同步里的 MysqlJsonDebeziumDeserializationSchema 的依赖使用的是 `org.apache.kafka.connect.json.JsonConverter`, 不能用胖包，需要用 kafka-client.jar 等依赖。 Dinky 中 1.16 的整库同步里的 MysqlJsonDebeziumDeserializationSchema 的依赖使用的是 `com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverter`，用胖包，只需要 flink-sql-connector-mysql-cdc-*.jar. 解决方式：推荐修改dinky 1.13的代码，改为 shaded 依赖。
How do you think it is more appropriate to assert?
Sorry. At present, I can't think of how to do it. Maybe you can refer to other open source projects. thx
> > > > the connection to other services is guaranteed according to the library unit tests, we only need to make sure invoke behavior is all right, so could...
目前 CDCSOURCE 不支持全局变量
> Dinky 0.7.1, Flink 1.16.0, MySQL 8.0.29, CDC connectors 2.3.0, Doris 1.2.1 环境下，在 CDCSOURCE 整库同步 mysql 到 doris 时同样遇到此问题！  我无法复现该问题
com.dlink.cdc.AbstractSinkBuilder.getLogicalType case TIMESTAMP: return new TimestampType(column.getLength());