Hi, Fenley ~ You are right, parsing nulls of ARRAY field is not supported now, i have logged an issue [1] and would fix it soon ~
[1] https://issues.apache.org/jira/browse/FLINK-20234 Rex Fenley <r...@remind101.com> 于2020年11月19日周四 下午2:51写道： > 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! > > (P.S. The exception was not that informative, there may be room for > improvement in terms of a richer error message when this happens.) > > -- > > Rex Fenley | Software Engineer - Mobile and Backend > > > Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> | > FOLLOW US <https://twitter.com/remindhq> | LIKE US > <https://www.facebook.com/remindhq> >
