在窗口内去重吧,不可能无限保留去重数据的


athlon...@gmail.com
 
发件人: lvwenyuan
发送时间: 2019-09-04 14:28
收件人: user-zh
主题: 关于Flink SQL DISTINCT问题
各位大佬好:
       我想问下,关于flink sql的实时去重,就是count(distinct user_id) 
。就是Flink内部是如何做到实时去重,如果对于数据量比较大的时候实时去重,是否会有性能问题。用的Blink Planner

回复