我看你还写到 “每分钟触发统计一次结果”，你是不是做了自定义trigger啥的，导致逻辑不对了。
默认情况就可以实现你要的效果，不要自定义trigger哈这里。 赵一旦 <[email protected]> 于2021年1月18日周一 下午3:52写道： > 补充下，是针对每个key，每1min输出一个结果。采用1h窗口，1min滑动窗口。 > > > > 赵一旦 <[email protected]> 于2021年1月18日周一 下午3:51写道： > >> 你貌似没懂我的意思。我的意思是你的需求和sliding window的效果应该就是一样的。 >> 不是很清楚你表达的最早什么的是什么含义。 >> >> 基于event time做sliding window，只要你没设置其他东西，就应该是1min输出一个结果而已哈。 >> >> eriendeng <[email protected]> 于2021年1月18日周一 上午11:42写道： >> >>> 只要sliding出来才满足你每分钟执行的滑动要求吧？至于你只要最早/新的某一条，你可以从window groupby得出的流再次group >>> by然后再用window时间筛选你要的数据。 >>> >>> >>> >>> -- >>> Sent from: http://apache-flink.147419.n8.nabble.com/ >> >>
