关于flinkstream 时间窗体的事件分割方式及使用问题-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

关于flinkstream 时间窗体的事件分割方式及使用问题

飘渺の混沌 2018-11-15 10:56:44 2579

在使用窗体进行流分割计算的时候,通过将stream注册成表可以拿到proctime.proctime, rowtime.rowtime 不同的时间,完成时间窗体的计算,如果对于这个动态表进行多段处理,即根据该表生成多个table,那么子table就无法使用
proctime.proctime, rowtime.rowtime

这里是将子table(最终结果)=》撤回流,通过timewindow进行聚合去除状态数据,并输出Retraction stream
异常:

如果想使用会报:Retraction on windowed GroupBy aggregation is not supported yet. Note: Windowed GroupBy aggregation should not follow a non-windowed GroupBy aggregation

请问这种应该如何解决,只用一级table动态表 进行窗口聚合没有问题,但是业务复杂度不支持

具体代码实现如下(一个带时间的表和2个不带时间的表json):
image

JSON 数据格式
分享到
取消 提交回答
全部回答(1)
大数据
使用钉钉扫一扫加入圈子
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题
推荐课程