hudi问题汇总

关于流读changelog问题

我们知道hudi可以开启changelog模式,保留消息变更信息(I/+U/-U/D),但是我们在查询变更消息时,需要注意的是需要在sql-client中设置以下两个参数,set sql-client.execution.result-mode=tableau;或者set sql-client.execution.result-mode=changelog;(参考:https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/dev/table/sqlclient/#running-sql-queries),不然那些中间结果在读的时候会被直接合并的,也就读不到U和D的数据。

0 0 投票数
文章评分

本文为从大数据到人工智能博主「xiaozhch5」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。

原文链接:https://lrting.top/backend/2363/

(0)
上一篇 2021-11-22 01:24
下一篇 2021-11-23 00:20

相关推荐

订阅评论
提醒
guest
0 评论
内联反馈
查看所有评论
0
希望看到您的想法,请您发表评论x
()
x