回复： flink sql upsert模式写入mysql，es等key一定是groupby之后所有字段吗

[1048262223]

Hi


这里存在一个问题是，使用了last_value或者first_value这样的udaf，但是如果多条数据来到经过udaf处理后结果还是和之前一样的情况下，是不会产出回撤流数据的，可以观察下你是否需要考虑这种情况。


Best,
Yichao Yang




--原始邮件--
发件人:"x2009438"https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/query_configuration.html#idle-state-retention-time
 

回复：flink sql upsert模式写入mysql，es等key一定是groupby之后所有字段吗

[kcz]

我大概get到你要说的需求，select那些其实是明细数据？但是没有跟聚合的数据拆开，所以才出现这种情况吧？





-- 原始邮件 --
发件人: Leonard Xu https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/query_configuration.html#idle-state-retention-time