大佬们，flinksql CDC建表后，执行select 的时候报错，麻烦看看是什么原因。
大佬们，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传进来了。
2022-12-07 07:33:04赞同 1 展开评论 打赏 -
字面意思呀，你的dt字段不允许为null，但是消费过来的数据里有null过来；要么排查下数据源为什么对dt字段会出选null，要么设置 ‘table.exec.sink.not-null-enforcer’=‘drop’（此答案整理自Flink CDC 社区）
2022-08-20 18:06:59赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
