flink这个报错是怎么回事?clickhouse : Table engine Distributed doesn’t support mutations. (NOT_IMPLEMENTED) (version 22.2.2.1)
flink这个报错是怎么回事?clickhouse : Table engine Distribu[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！
=====这是一个广告位，招租中，联系qq 78315851====
这个报错是因为Flink在尝试将数据写入ClickHouse时，遇到了分布式表引擎不支持mutations的问题。mutations是指对已有数据的修改操作，而分布式表引擎通常用于支持大量数据的读取和查询，但不支持修改操作。
要解决这个问题，你可以尝试以下方法：
使用非分布式表引擎，例如本地表或单机表。这样，你可以在Flink中直接进行修改操作。
如果你确实需要使用分布式表引擎，可以考虑将数据先写入一个临时表，然后再将临时表的数据导入到ClickHouse的分布式表中。这样，你可以在Flink中对临时表进行修改操作，然后再将修改后的数据导入到分布式表中。
对于mutations执行失败的话，先去查询system.mutations的任务，查看is_done=0的数据，并且看下latest_fail_reason的原因。如果发现问题不是sql的原因，则删除mutations再尝试执行删除或者更新，如果是sql或者其他原因，查询找到原因解决再执行删除或者更新。