嗯,这应该是一个实现的bug,可以提个issue修复一下~

史 正超 <[email protected]> 于2020年10月14日周三 上午10:19写道:

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


-- 

Best,
Benchao Li

回复