Flink 中是否需要 RETRACT 流？

Question

在 Flink 中使用 RETRACT 流时，update 消息分两阶段完成，而使用 UPSERT 流时，则分阶段完成，效率更高。

但是，根据this page将Dynamic table转换为DataStream时不允许使用UPSERT流，为什么会有这样的限制？在 Flink 的设计中，将 RETRACT 全部替换为 UPSERT 会遇到什么样的问题？

Answer 1

我们在 Flink 的设计中将 RETRACT 全部替换为 UPSERT 会遇到哪些问题？

作为您链接到的页面，upsert 流需要一个主键。因此，摆脱作为一个概念的撤回流将破坏您没有此类密钥（根本或只是未定义）的所有场景。