flink 导入报错

确认是这是脏数据还是?

原数据是在kafka中的嘛?可以检验下?
另外请问下使用的哪个版本?哪种数据模型?flink-connector哪个版本?