[ https://issues.apache.org/jira/browse/FLINK-18590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157159#comment-17157159 ]
Benchao Li commented on FLINK-18590: ------------------------------------ I also thought about the way how we should add this, there is two ways come into my head: 1. do an implicit conversion, we can use {{JsonNode#isArray()}} to do this; 2. do an explicit conversion, this way, we need an option. Both ways are ok to me. I'm a little lean to #1, because it can handle both kinds of data at the same time. > Support json array explode to multi messages > -------------------------------------------- > > Key: FLINK-18590 > URL: https://issues.apache.org/jira/browse/FLINK-18590 > Project: Flink > Issue Type: Improvement > Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Reporter: Benchao Li > Priority: Major > > Currently our {{DeserializationSchema}} has supported to emit multi messages > for one input record. There is some cases that the json data is not a json > object in top level, for example: > {code:SQL} > CREATE TABLE source ( > col1 int, > col2 varchar > ) WITH ( > ... > 'format' = 'json' > ) > {code} > With following data. > {code:json} > [ > {"col1": 1, "col2": "hello"}, > {"col1": 2, "col2": "flink"} > ] > {code} > CC [~jark] -- This message was sent by Atlassian Jira (v8.3.4#803005)