Marios Trivyzas created FLINK-25008:
---------------------------------------
Summary: Improve behaviour of NotNullEnforcer when dropping records
Key: FLINK-25008
URL: https://issues.apache.org/jira/browse/FLINK-25008
Project: Flink
Issue Type: Improvement
Reporter: Marios Trivyzas
By default *NotNullEnforcer* is configured as *ERROR,* so if a record with
*null* value(s) for the corresponding column(s) marked as *NOT NULL* is
processed an error is thrown. User can change the configuration and choose
*DROP* so those records would be silently dropped and not end up in the sink.
Maybe it worths adding another option, like *LOG_AND_DROP* so that those
records are not silently dropped, but instead end up in some log and facilitate
easier debugging or post-processing of the pipeline.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
