内层query不是按时间窗查询的话，这恐怕是不支持。 如果内层query是按时间窗的，比如固定窗口，那还可以用tumble_rowtime来传递rowtime属性。
-----邮件原件----- 发件人: 金圣哲 <[email protected]> 发送时间: Friday, November 15, 2019 1:21 PM 收件人: [email protected] 主题: flink sql 状态表嵌套窗口查询 各位老板好: "select rider_id, waybill_status as waybill_status ,count(id) as waybill_status_count, TUMBLE_START(ctime, INTERVAL '1' DAY) as wStart from (select id, min(ctime) as rowtime ,latest(status, utime) as waybill_status, latest(rider_id, utime) as rider_id from user group by id) group by TUMBLE(ctime, INTERVAL '1' DAY),waybill_status,rider_id" 问一下 想用状态表作为子表 外面嵌套窗口 如何实现呢 因为状态表group by之后 ctime会失去时间属性 哪位老板知道
