[FLINK-14739] add failOnCastException Configuration to Json FormatDescriptor

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.9.1
• Fix Version/s: 1.9.4
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
• Labels: auto-deprioritized-major
• Assignee: Unassigned
• Reporter: Jun Zhang
• Created: 13/Nov/19 09:43
• Updated: 29/Apr/21 23:20

Description

When flink read data from kafka (format is json), the schema is defined, similar to the following DDL

CREATE TABLE kafka_source (
  intotime VARCHAR,
  userinfo ROW<name VARCHAR,age int>
) WITH (
   'connector.type' = 'kafka',
   'format.type' = 'json',
    .............
)

But when flink encounters error data, such as the type of userinfo is a string, the program will throw the following exception and then fail.

Caused by: java.lang.ClassCastException: org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.TextNode cannot be cast to org.apache.flink.shaded.jackson2.com.fasterxml.jackson. databind.node.ObjectNode

I want to find the wrong data and don't want the program to fail. So I want to add a json configuration, just like org.apache.flink.table.descriptors.Json#failOnMissingField, which allows the user to configure.