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)
