[
https://issues.apache.org/jira/browse/FLINK-24753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marios Trivyzas updated FLINK-24753:
------------------------------------
Description:
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)*
was:
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.
> 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
> 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)
