FlinkYou can set job configuration ‘table.exec.sink.not-null-enforcer‘=‘drop‘ to suppress this exc

Posted 2022-12-30 九师兄

文章目录

• 1.概述

1.概述

Flink写入源头数据是正常的。但是报这个错：You can set job configuration \'table.exec.sink.not-null-enforcer\'=\'drop\' to suppress this exception and drop such records silently

根据报错找到报错位置：

 private Transformation<RowData> applyNotNullEnforcer(
            TableConfig config,