[FLINK-20459] Handle null message correctly in JSON RowData deserializer

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
• Assignee: Unassigned
• Reporter: Qingsheng Ren
• Created: 03/Dec/20 04:03
• Updated: 03/Dec/20 04:13
• Resolved: 03/Dec/20 04:13

Description

Currently if the input message of the `deserialize()` method is null and the deserializer is not ignoring parse errors, `new String(message)` in the exception part will lead to an NPE.

 

A possible solution is returning null directly if the input message is null, but I'm not sure if this is a correct behavior since a null message can be treated as a "corrupted" message which cannot be deserialized as JSON and should lead to an exception. 

Issue Links

• is duplicated by: FLINK-20321 Get NPE when using AvroDeserializationSchema to deserialize null input