时间属性字段传递问题，有办法解决吗？
我向做两次的窗口计算。 1、第一次5分钟窗口。 2、第二次10分钟窗口，使用的上一次窗口的结果。
我尝试了发生了异常， Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered.
请问有什么办法可以解决吗？ 我希望是一个窗口计算后面可以再接一个窗口计算。
第一次计算：
CREATE VIEW tmp_5min AS SELECT
max(rowtime) as rowtime, TUMBLE_START(rowtime, INTERVAL '5' minute) AS window_start,
user_group， COUNT(*) AS cnt FROM user_behavior
GROUP BY
TUMBLE(rowtime, INTERVAL '5' minute),
user_group
第二次计算：
CREATE VIEW tmp_10min AS SELECT
max(rowtime) as rowtime, TUMBLE_START(rowtime, INTERVAL '10' minute) AS window_start,
user_group， SUM(cnt) AS sum_cnt FROM tmp_5min
GROUP BY
TUMBLE(rowtime, INTERVAL '10' minute),
user_group*来自志愿者整理的flink邮件归档
写回答
-
知道了，使用TUMBLE_ROWTIME HOP_ROWTIME SESSION_ROWTIME 可以传递了。
*来自志愿者整理的flink
2021-12-08 11:19:17赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
