snuyanzin commented on a change in pull request #17811:
URL: https://github.com/apache/flink/pull/17811#discussion_r752257191
##########
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java
##########
@@ -388,6 +409,20 @@
DROP
}
+ /**
+ * The enforcer to guarantee that precision of CHAR/VARCHAR columns is
respected when writing
+ * data into sink.
+ */
+ public enum CharPrecisionEnforcer {
+ /**
+ * Throws runtime exception when writing string values exceeding the
length defined in the
+ * type .
+ */
+ ERROR,
+ /** Trip string values to match the length defined as the CHAR/VARCHAR
precision. */
Review comment:
Probably Trims (with s at the end) as `Throws` for `ERROR`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
