关于流读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的数据。
本文为从大数据到人工智能博主「xiaozhch5」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://lrting.top/backend/2363/
