Benchao Li created FLINK-18590: ---------------------------------- Summary: 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
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)