paimon changelog producer区别和选择
https://paimon.apache.org/docs/1.3/primary-key-table/changelog-producer/ 这几种模式的区别是什么 如何选择
如何选择
如何生成changelog
flink normalize算子
flink normalize算子的是否插入是否参数可控
目前 260715 没有参数可控
用户没法直接强制关闭。这一点在 Flink JIRA FLINK-29625: Optimize changelog normalize for upsert source 里能看到——社区里就有人明确提过"希望能有个 option 关掉它",说明当前没有这个开关,是个待补的能力(配合我们前面聊的 FLIP-510、FLINK-37475,社区正在做的就是让 Planner 自己更聪明地判断"什么时候真的不需要插入",而不是给用户一个手动开关)。
flink normalize算子是否插入 和上游有关吗
有关
多个source怎么处理的
是否normalize算子 和 配置table.exec.sink.upsert-materialize 有关吗
无关
详解 table.exec.sink.upsert-materialize
该配置针对什么流
它针对的是所有"更新类(changelog)流"写入带主键的 Sink 的场景,不局限于"upsert-only 流"(缺-U的那种)
flink如何识别是否需要插入 SinkUpsertMaterializer 算子
sinkUpsertMaterializer处理案例
sinkUpsertMaterializer 是添加算子 算子位置在哪里
为什么paimon aggregation中要求 table.exec.sink.upsert-materialize 设置为NONE
https://paimon.apache.org/docs/master/primary-key-table/merge-engine/aggregation/#product
