【flink】非窗口聚合与窗口聚合join说明
发布时间
阅读量：
阅读量
文章结构概览
-
-
-
- 需求
- 所面临的问题
- 最终生成的SQL语句
-
-
需求
（source1 申请表 source2 结果表）
要求输出4个字段：
申请表当前的数量，
结果表当前的数量，
申请表近1小时的数量，
结果表近1小时的数量，
问题识别与分析
1.Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before.
官网解释：https://help.aliyun.com/document_detail/160117.html?spm=5176.10695662.1996646101.searchclickresult.d7fb34754vQOA7#section-spd-rv9-njx
报错原因
双流JOIN的ON条件中包含时间属性字段。
解决方案
删除双流JOIN中包含时间属性字段的ON条件。
通过CASET或TO全部评论 (0)
还没有任何评论哟~