[FLINK-18590] Support json array explode to multi messages

• Type: Sub-task
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
• Labels: auto-deprioritized-major auto-unassigned pull-request-available
• Assignee: Unassigned
• Reporter: Benchao Li
• Created: 14/Jul/20 02:58
• Updated: 28/Feb/23 08:59

Description

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:

CREATE TABLE source (
  col1 int,
  col2 varchar
) WITH (
  ...
  'format' = 'json'
)

With following data.

[
{"col1": 1, "col2": "hello"},
{"col1": 2, "col2": "flink"}
]

CC jark

Issue Links

• links to: Flink SQL handle top-level Array JSON
• links to: GitHub Pull Request #13081
• links to: Nested Json parsing exception