从报错信息可以看出,好像是由于 State Serializer 不兼容导致的
1 个赞
北极星DB
(Ti D Ber H0 A Jl5 Tn)
6
Flink CDC的版本也可以升级试试吧,不仅仅是TiDB的版本,可能是两者不兼容导致的吧
1 个赞
异乡的大人
(Ti D Ber 2 Qs S2z Ws)
7
可能是TiDB与Flink CDC版本不匹配,更换一下版本
异乡的大人
(Ti D Ber 2 Qs S2z Ws)
8
还有可能是State Serializer不兼容或反序列化对象失败