可以再解释一下吗?还是没有看太懂是哪里出错,以及为什么那样就可以解决问题。
------------------ 原始邮件 ------------------ 发件人: Tianwang Li <litianw...@gmail.com> 发送时间: 2020年8月6日 21:40 收件人: user-zh <user-zh@flink.apache.org> 主题: 回复:请教:时间属性字段传递问题,有办法解决吗? 知道了,使用TUMBLE_ROWTIME HOP_ROWTIME SESSION_ROWTIME 可以传递了。 Tianwang Li <litianw...@gmail.com> 于2020年8月6日周四 下午9:12写道: > > 我向做两次的窗口计算。 > 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 > > > > -- > ************************************** > tivan > ************************************** > -- ************************************** tivanli **************************************