Re: flink1.12.2 sql session窗口间隔时间段内没有新数据窗口不关闭

2021-06-18 文章 yidan zhao
感觉应该是水印时间没到的原因,和session window本身关系不大。

raofang <295070...@qq.com.invalid> 于2021年6月18日周五 下午12:54写道:
>
> hi,请教大家一个问题:
> flink1.12.2 sql BlinkPlanner
> 使用基于routime的session窗口时,在设置的间隔时间10分钟内没有接收到新数据,窗口没有关闭输出计算结果;但是接收到10分钟之后的新数据时上一次的session窗口才关闭输出结果。不知道是什么原因导致超过间隔时间没有新数据窗口没有关闭的问题呢?
>  谢谢~
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/


Re: flink1.12.2 sql session窗口间隔时间段内没有新数据窗口不关闭

2021-06-18 文章 lpengdr...@163.com
你用EventTimeSession窗口的超时也是按照你的事件时间来判断的,要有超过超时时间边界的数据输入了才能触发



lpengdr...@163.com
 
发件人: raofang
发送时间: 2021-06-18 12:20
收件人: user-zh
主题: flink1.12.2 sql session窗口间隔时间段内没有新数据窗口不关闭
hi,请教大家一个问题:
flink1.12.2 sql BlinkPlanner
使用基于routime的session窗口时,在设置的间隔时间10分钟内没有接收到新数据,窗口没有关闭输出计算结果;但是接收到10分钟之后的新数据时上一次的session窗口才关闭输出结果。不知道是什么原因导致超过间隔时间没有新数据窗口没有关闭的问题呢?
 谢谢~
 
 
 
--
Sent from: http://apache-flink.147419.n8.nabble.com/


flink1.12.2 sql session窗口间隔时间段内没有新数据窗口不关闭

2021-06-17 文章 raofang
hi,请教大家一个问题:
flink1.12.2 sql BlinkPlanner
使用基于routime的session窗口时,在设置的间隔时间10分钟内没有接收到新数据,窗口没有关闭输出计算结果;但是接收到10分钟之后的新数据时上一次的session窗口才关闭输出结果。不知道是什么原因导致超过间隔时间没有新数据窗口没有关闭的问题呢?
 谢谢~



--
Sent from: http://apache-flink.147419.n8.nabble.com/