DDL中声明主键会报类型不匹配怎么解决？
Hi： flink版本1.11.0 connector为kafka DDL中声明某个字段为primary key时，会报类型不匹配，去掉primary key constraint就可以正常执行。 把shop_id设置为 varchar not null也不行。
org.apache.flink.table.api.ValidationException: Type STRING NOT NULL of table field 'shop_id' does not match with the physical type STRING of the 'shop_id' field of the TableSource return type.
SQL如下： create table source_0 ( shop_id varchar, user_id bigint, category_id int, ts bigint, proc_time as PROCTIME(), event_time AS TO_TIMESTAMP(FROM_UNIXTIME(ts / 1000, 'yyyy-MM-dd HH:mm:ss')), watermark for event_time AS event_time, PRIMARY KEY (shop_id, user_id) NOT ENFORCED ) with ( 'connector.type' = 'kafka',
) *来自志愿者整理的flink邮件归档
写回答
-
是的 加了 primary key constraint 后会强制将类型转成 Not nullable，这个是 primary key 的特性导致的。*来自志愿者整理的flink
2021-12-07 20:22:57赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
