flink sql hop函数窗口时间前移问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink sql hop函数窗口时间前移问题

bigdata
你好:
        我是用的flink1.10.1,使用滑动窗口时候,第一个窗口的开启时间会前移。前移时长=窗口时长-滑动步长。这就导致刚接到的第一条数据(在前移时长范围内)一直参与计算。如何解决,谢谢!