大佬们,flinksql CDC建表后,执行select 的时候报错,麻烦看看是什么原因。
Column ‘dt’ is NOT NULL, however, a null value is being written into it. You can set job configuration ‘table.exec.sink.not-null-enforcer’=‘drop’ to suppress this exception and drop such records silently.
如果你的数据源是mysql,那应该是mysql表中字段大小写和你Flink DDL语句中的字段大小写不一致导致的。它这个是严格区分大小写的。否则,它会认为mysql中没有相关字段,是null传进来了。
字面意思呀,你的dt字段不允许为null,但是消费过来的数据里有null过来;要么排查下数据源为什么对dt字段会出选null,要么设置 ‘table.exec.sink.not-null-enforcer’=‘drop’(此答案整理自Flink CDC 社区)
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。