flink 处理tidb数据 启动时经常出现空指针异常

启动任务后经常出现该报错


或者

但是过一会儿就好了

从报错信息可以看出,好像是由于 State Serializer 不兼容导致的

1 个赞

版本不兼容

1 个赞

Flink CDC的版本也可以升级试试吧,不仅仅是TiDB的版本,可能是两者不兼容导致的吧

1 个赞

可能是TiDB与Flink CDC版本不匹配,更换一下版本

还有可能是State Serializer不兼容或反序列化对象失败

可能TiDB CDC连接器版本兼容性问题

最好用工具包自带的cdc