[jira] [Created] (FLINK-16220) JsonRowSerializationSchema throws cast exception : NullNode cannot be cast to ArrayNode

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-16220) JsonRowSerializationSchema throws cast exception : NullNode cannot be cast to ArrayNode

Shang Yuanchun (Jira)
Benchao Li created FLINK-16220:
----------------------------------

             Summary: JsonRowSerializationSchema throws cast exception : NullNode cannot be cast to ArrayNode
                 Key: FLINK-16220
                 URL: https://issues.apache.org/jira/browse/FLINK-16220
             Project: Flink
          Issue Type: Bug
          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
            Reporter: Benchao Li


It's because the object reuse. For the below schema:
{code:java}
create table sink {
  col1 int,
  col2 array<int>
}{code}
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] 



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