从你的异常来看,你用的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/
