开发者社区 问答 正文

Flink报错doesn't support consuming update and delete

已解决

Flink报错doesn't support consuming update and delete changes which is produced by node TableSourceScandoesn't support consuming update and delete changes which is produced by node TableSourceScan

展开
收起
阿里云服务支持 2022-12-20 14:03:13 2253 分享 版权
1 条回答
写回答
取消 提交回答
  • 官方回答

    语法校验报错,append类型sink无法接收上游update记录。

    使用支持写入update记录的sink,如upsert-kafka等。

    2022-12-20 14:13:26
    赞同 展开评论
收录在圈子:
作为全球云计算的领先者,阿里云为全球230万企业提供着云计算服务,服务范围覆盖200多个国家和地区。我们致力于为企业、政府等组织机构提供安全可靠的云计算服务,给用户带来极速愉悦的服务体验。
还有其他疑问?
咨询AI助理