[
https://issues.apache.org/jira/browse/FLINK-25008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447748#comment-17447748
]
Jark Wu commented on FLINK-25008:
---------------------------------
Sounds good to me.
> Improve behaviour of NotNullEnforcer when dropping records
> ----------------------------------------------------------
>
> Key: FLINK-25008
> URL: https://issues.apache.org/jira/browse/FLINK-25008
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / Planner
> Reporter: Marios Trivyzas
> Priority: Major
>
> 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)
