从你的异常来看,你用的format是 avro, 我看了下源码,他对varchar类型的covert和json不一样,avro的代码是这样的:

case CHAR:
case VARCHAR:
   return avroObject -> StringData.fromString(avroObject.toString());

所以,你的map类型的value值为null,会报空指针异常的。
________________________________
发件人: 奔跑的小飞袁 <[email protected]>
发送时间: 2020年10月14日 1:46
收件人: [email protected] <[email protected]>
主题: Re: flink-SQL1.11版本对map类型中value的空指针异常

other_para MAP<VARCHAR,VARCHAR>



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复