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
请大佬们帮忙看下,谢谢
