[jira] [Updated] (FLINK-19622) flinksql 1.11版本针对avro格式中Map类型value值的空指针异常

["宋洪亮 (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-19622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

宋洪亮 updated FLINK-19622:
------------------------
          Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
    Affects Version/s: 1.11.1

> flinksql 1.11版本针对avro格式中Map类型value值的空指针异常
> -----------------------------------------
>
>                 Key: FLINK-19622
>                 URL: https://issues.apache.org/jira/browse/FLINK-19622
>             Project: Flink
>          Issue Type: Bug
>          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
>    Affects Versions: 1.11.1
>         Environment: 下面附上源码 AvroRowDataDeserializationSchema
> {code:java}
> 私有 静态DeserializationRuntimeConverter createMapConverter（LogicalType类型）{
>    最终DeserializationRuntimeConverter keyConverter = createConverter（
>       DataTypes.STRING（）。getLogicalType（））;
>    最后的DeserializationRuntimeConverter valueConverter = createConverter（
>       extractValueTypeToAvroMap（type））;
>    返回avroObject-> {
>        final Map <?,？> map =（Map <?,？>）avroObject;
>       Map < Object，Object > result = new HashMap <>（）;
>       对于（Map.Entry <?,？> entry：map.entrySet（））{
>          对象键= keyConverter.convert（entry.getKey（））;
>          对象值= valueConverter.convert（entry.getValue（））;
>          result.put（key，value）;
>       }
>       返回 新的GenericMapData（result）;
>    };
> }
> {code}
>            Reporter: 宋洪亮
>            Priority: Critical
>
> hello，我在使用flinksql 1.11版本针对kafka中avro格式的数据解析时，使用到了Map类型，针对此类型我的定义是MAP<VARCHAR,VARCHAR>，但是在解析是由于map中的value为空我碰到了空指针异常
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)