Table sink ‘default_catalog.default_database.t3‘ doesn‘t support consuming update and delete changes
Table sink 'default_catalog.default_database.t3' doesn't support consuming update and delete changes
·
报错：Table sink ‘default_catalog.default_database.t3’ doesn’t support consuming update and delete changes which is produced by node Join
原因：kafka不支持left join中的更新和删除操作：
解决方法：使用upsert-kafka
upsert-kafka的使用方法去官网查询即可
魔乐社区（Modelers.cn) 是一个中立、公益的人工智能社区，提供人工智能工具、模型、数据的托管、展示与应用协同服务，为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作，由全产业链共同建设、共同运营、共同享有，推动国产AI生态繁荣发展。
更多推荐
1
0- 0
已为社区贡献11条内容
所有评论(0)