You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/11/03 14:06:00 UTC
[jira] [Assigned] (FLINK-24753) Enforce CHAR/VARCHAR precision when
outputing to a Sink
[ https://issues.apache.org/jira/browse/FLINK-24753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Marios Trivyzas reassigned FLINK-24753:
---------------------------------------
Assignee: Marios Trivyzas
> 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)