Danny Chen created FLINK-20234: ---------------------------------- Summary: Json format supports SE/DE null elements of ARRAY type field Key: FLINK-20234 URL: https://issues.apache.org/jira/browse/FLINK-20234 Project: Flink Issue Type: Improvement Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile) Affects Versions: 1.11.2 Reporter: Danny Chen Fix For: 1.12.0
Report my USER mailing list: Hi, I recently discovered some of our data has NULL values arriving in an ARRAY<STRING> column. This column is being consumed by Flink via the Kafka connector Debezium format. We seem to be receiving NullPointerExceptions for when these NULL values in the arrays arrive which restarts the source operator in a loop. Is there any way to not throw or to possibly filter out NULLs in an Array of Strings in Flink? We're somewhat stuck on how to solve this problem, we'd like to be defensive about this on Flink's side. Thanks! -- This message was sent by Atlassian Jira (v8.3.4#803005)