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

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

宋洪亮 created FLINK-19622:
---------------------------

             Summary: flinksql 1.11版本针对avro格式中Map类型value值的空指针异常
                 Key: FLINK-19622
                 URL: https://issues.apache.org/jira/browse/FLINK-19622
             Project: Flink
          Issue Type: Bug
         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: 宋洪亮


hello，我在使用flinksql 1.11版本针对kafka中avro格式的数据解析时，使用到了Map类型，针对此类型我的定义是MAP<VARCHAR,VARCHAR>，但是在解析是由于map中的value为空我碰到了空指针异常

 

 



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