为提高效率,请提供以下信息,问题描述清晰能够更快得到解决:
【概述】 场景 + 问题概述
目前是想把Tidb的数据读取出来,然后经过一些业务逻辑后,写入另外一个库。
利用flink-sql-connectortidb-cdc从Tidb读数据,但是上传flink 任务总是提示 ClassNotFound
org.apache.fliink.cdc.connectors.tidb.TikvsnapshotEventDeserializationSchema
【应用框架及开发适配业务逻辑】
【背景】 做过哪些操作
【现象】 业务和数据库现象
【问题】 当前遇到的问题
【业务影响】
【TiDB 版本】
Tidb 6.5
Flink 2.0.0
flink-sql-connectortidb-cdc 3.4.0
【附件】 相关日志及监控
Kongdom
(Kongdom)
2
是不是版本太低不支持?看别的地方是可以的,只是有乱码的情况。
目前看是 flink2.0.0 flink-sql-connectortidb-cdc 3.0.4
flink lib用的依赖的flink相关jar是2.0的,flink-sql-connectortidb-cdc 依赖的是flink相关jar是1.19.1 ,导致版本有问题