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

upsert materialize operator(SinkUpsertMaterializer) 什么场景会多输出

paimon 'sequence.field'