开发者社区 问答 正文

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 2183 分享 版权
1 条回答
写回答
取消 提交回答
  • 官方回答

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

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

    2022-12-20 14:13:26
    赞同 展开评论