开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink这个报错是怎么回事?clickhouse : Table engine Distribu

flink这个报错是怎么回事?clickhouse : Table engine Distributed doesn't support mutations. (NOT_IMPLEMENTED) (version 22.2.2.1)

展开
收起
爱喝咖啡嘿 2022-12-11 19:41:54 3347 3
2 条回答
写回答
取消 提交回答
  • 全栈JAVA领域创作者

    这个报错是因为Flink在尝试将数据写入ClickHouse时,遇到了分布式表引擎不支持mutations的问题。mutations是指对已有数据的修改操作,而分布式表引擎通常用于支持大量数据的读取和查询,但不支持修改操作。

    要解决这个问题,你可以尝试以下方法:

    1. 使用非分布式表引擎,例如本地表或单机表。这样,你可以在Flink中直接进行修改操作。

    2. 如果你确实需要使用分布式表引擎,可以考虑将数据先写入一个临时表,然后再将临时表的数据导入到ClickHouse的分布式表中。这样,你可以在Flink中对临时表进行修改操作,然后再将修改后的数据导入到分布式表中。

    2023-07-01 07:55:45
    赞同 2 展开评论 打赏
  • 一个九年资深的程序员,擅长数据库、Java、C#、系统运维、电脑技巧等方面知识,阿里云专家博主、C站站优质博主、公众号运营超五年,热爱分享IT技术相关技术文章,给大家提供帮助!

    对于mutations执行失败的话,先去查询system.mutations的任务,查看is_done=0的数据,并且看下latest_fail_reason的原因。如果发现问题不是sql的原因,则删除mutations再尝试执行删除或者更新,如果是sql或者其他原因,查询找到原因解决再执行删除或者更新。

    2022-12-15 09:48:37
    赞同 1 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载