flinksql 写入 kudu表不能用upsert更新

Question

pk哥，flinksql 写入 kudu表不能用upsert更新，只能用insert，我在网上也没有找到相关的方法和udf，我现在有一个需求是需要upsert kudu表，希望您能给点建议

Answer 1

Michael_PK 2022-01-18 00:54:46

Flink的是不是考虑和CH搭配使用更合适呢

Answer 2

Michael_PK 2022-01-18 00:54:11

这个整合我真没做过。。。

• 提问者 精慕门4584454 #1

  我们公司现在没有用ch，flinksql确实不支持upsert kudu，我现在用的方法是先用source表left join原表再insert原表，但愿可以实现吧

• Michael_PK 回复 提问者 精慕门4584454 #2

  update的操作 使用你说的join肯定是可以实现的，但是性能上会差很多