[
https://issues.apache.org/jira/browse/FLINK-24753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438133#comment-17438133
]
Timo Walther commented on FLINK-24753:
--------------------------------------
The next step would be to include FLINK-24608 as well and make
`SinkConstraintValidator` rather a `SinkPreProcessor` (naming up for
discussion).
> Enforce CHAR/VARCHAR precision when outputing to a Sink
> -------------------------------------------------------
>
> Key: FLINK-24753
> URL: https://issues.apache.org/jira/browse/FLINK-24753
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Runtime
> Reporter: Marios Trivyzas
> Assignee: Marios Trivyzas
> Priority: Major
>
> When a column is declared with *CHAR/VARCHAR* with a specific precision, i.e.
> *CHAR(10)* a sink that would require following this precision strictly (like
> a relational DB) would throw errors if the records received exceed this limit.
>
> Add an operator similar to the one *SinkNotNullEnforcer* and possible merge
> this functionality into one operator (i.e. *SinkConstraintValidator)*
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
