[FLINK-16220] JsonRowSerializationSchema throws cast exception : NullNode cannot be cast to ArrayNode

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.1, 1.11.0
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
• Labels: pull-request-available
• Assignee: Benchao Li
• Reporter: Benchao Li
• Created: 21/Feb/20 14:42
• Updated: 20/Mar/20 06:45
• Resolved: 20/Mar/20 06:45

Description

It's because the object reuse. For the below schema:

create table sink {
  col1 int,
  col2 array<int>
}

if col2 is null, then the reused object will be NullNode. for the next record, if it's not null, we will cast the reused object NullNode to ArrayNode, which will throw cast exception.

 

cc jark twalthr 

Issue Links

• duplicates: FLINK-16628 Complex JSON sink into kafka error
• links to: GitHub Pull Request #11180