Hi all :
 kafka 
第一次发送统计信息延迟。如果从kafka发送一条消息,第一次的count统计,每次都是在发送第二条消息的时候,才会统计出来。正常情况下,应该是发送一条统计一条,现在的情况是发送第二条消息的时候,才会统计出第一条消息的。
代码如下:
select terminal_only_no,count(distinct(certificate_no)) OVER(PARTITION BY 
terminal_only_no ORDER BY event_time RANGE BETWEEN INTERVAL '10' MINUTE 
preceding AND CURRENT ROW) as login_frequency from TradeFlow

请大佬们帮忙看下,谢谢  

回复