This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a675ed8 [FLINK-25150][API] Fix the violation of api annotation
add c35c5b5 [hotfix][table-runtime Improve performance of UpdatableRowData
add 1151071 [FLINK-24753] Implement CHAR/VARCHAR length validation for
sinks
No new revisions were added by this update.
Summary of changes:
.../generated/execution_config_configuration.html | 8 +-
.../7602816f-5c01-4b7a-9e3e-235dfedec245 | 2 +-
.../src/test/resources/sql/table.q | 4 +-
.../table/api/config/ExecutionConfigOptions.java | 73 +++++-
.../plan/nodes/exec/common/CommonExecSink.java | 78 ++++--
.../nodes/exec/common/CommonExecSinkITCase.java | 272 ++++++++++++++-----
.../runtime/batch/table/TableSinkITCase.scala | 88 +------
.../runtime/stream/table/TableSinkITCase.scala | 172 +-----------
.../apache/flink/table/data/UpdatableRowData.java | 44 ++--
.../runtime/operators/sink/ConstraintEnforcer.java | 289 +++++++++++++++++++++
.../operators/sink/SinkNotNullEnforcer.java | 71 -----
11 files changed, 656 insertions(+), 445 deletions(-)
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/ConstraintEnforcer.java
delete mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkNotNullEnforcer.java
