这个应该是因为watermark的原因吧。比如你的watermark生成策略是不是固定的delay的方式？
Fei Han <[email protected]> 于2020年4月7日周二 下午12:02写道： > > 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 > > 请大佬们帮忙看下，谢谢 > -- Benchao Li School of Electronics Engineering and Computer Science, Peking University Tel:+86-15650713730 Email: [email protected]; [email protected]
