阿里云文档 2024-08-05

窗口聚合

实时计算Flink版的窗口聚合支持老语法分组窗口聚合(Group Window Aggregation)和新语法窗口表值函数聚合(Window TVF Aggregation)两种形式。本文为您介绍窗口聚合新老语法详情、窗口表值函数和聚合语句无法合并的场景、以及新老语法对更新流的支持情况。

问答 2024-04-14 来自:开发者社区

请问下,flink1.18在允许等待的范围内,来原先窗口的数据,窗口还会再次触发吗?

请问下,flink1.18TumblingEvent time windows 设置allowedLateness后,如果窗口到达触发时间,触发后,在允许等待的范围内,来原先窗口的数据,窗口还会再次触发吗?

问答 2023-12-03 来自:开发者社区

flink sql写累积窗口 开一天 每5分钟输出一次数据,为啥最后没有触发计算啊?

flink sql写累积窗口 开一天 每5分钟输出一次数据,为啥最后没有触发计算啊?

问答 2023-12-03 来自:开发者社区

有那位遇到这种情况:flink任务:,以至于当前的任务窗口无法触发计算?

有那位大佬遇到这种情况:1.问题:flink任务:存在数据大于当前时间一年的数据,导致水位线推进到一年以后,以至于当前的任务窗口无法触发计算2.任务描述:1.创建kafka的动态表;2.创建视图进行过滤:基于该动态表设置时间过滤条件(时间小于等于当前时间+1 天的数据),但是水位线仍然会推进到大于当前时间一年的3.疑惑:明明已经过滤脏数据,为什么水位线还会推进,是这个过滤条件加的位置不对,时间过....

问答 2023-11-30 来自:开发者社区

Flink数据源长时间没有数据进来,窗口的触发器怎么触发执行?

Flink数据源长时间没有数据进来,窗口的触发器怎么触发执行?

问答 2023-09-28 来自:开发者社区

Flink 窗口事件时间触发器是增量触发吗?

Flink 窗口事件时间触发器是增量触发吗?还是触发的所有数据,我现在这里触发的数据有点乱序了?看着像增量触发的啊,看着像触发的全量,我用事件时间 大于等于水印过滤掉了?

问答 2023-08-16 来自:开发者社区

Flink CDC是非要等下一条数据发送,依赖下一条数据携带时间戳大于窗口的结束时间才会真正的触发?

Flink CDC中我这边在使用Flink的事件时间窗口的时候,关于窗口触发的条件我有一点疑问想咨询一下各位老师我是开了一个2分钟的事件时间的窗口,但是等到两分钟后窗口并没有主动触发,等我后面再发一条数据的时候,窗口再进行了触发所以我想请问窗口的触发机制不是时间点嘛,而是非要等到下一条数据发送,依赖于下一条数据携带的时间戳大于窗口的结束时间,上一个窗口才会真正的触发嘛?

问答 2023-08-14 来自:开发者社区

各位老师好,我这边在使用Flink的事件时间窗口的时候,关于窗口触发的条件我有一点疑问想咨询一下?

问题1:各位老师好,我这边在使用Flink的事件时间窗口的时候,关于窗口触发的条件我有一点疑问想咨询一下各位老师我是开了一个2分钟的事件时间的窗口,但是等到两分钟后窗口并没有主动触发,等我后面再发一条数据的时候,窗口再进行了触发所以我想请问一下窗口的触发机制不是时间点嘛,而是非要等到下一条数据发送,依赖于下一条数据携带的时间戳大于窗口的结束时间,上一个窗口才会真正的触发嘛?请各位老师指导一下?问....

问答 2023-08-09 来自:开发者社区

请教一下Flink 渐进式窗口 cumulate 的触发频率是 怎么控制的?

请教一下Flink 渐进式窗口 cumulate 的触发频率是 怎么控制的?

问答 2023-08-08 来自:开发者社区

咨询一下Flink,滚动窗口1小时,每小时都有一条数据,为什么窗口触发延时了8小时呢?这个怎么排查呢

咨询一下Flink,滚动窗口1小时,每小时都有一条数据,为什么窗口触发延时了8小时呢?这个怎么排查呢?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等