sql如下: with effective_chargeorder as ( select o.recordcreatedtime,o.recordcreateduser,o.status,o._is_delete,o.appointmentid,o.id,o.tenantid,o.actualprice,o.proc_time from t_k_chargeorder as o where o.recordcreateduser > 0 and o.status NOT IN ( '已作废', '未收费', '作废并撤回', '等待支付宝付费', '等待微信付费' ) and o._is_delete = '0' and o.appointmentid > 0 ) --select * from effective_chargeorder; SELECT window_start, window_end, SUM(actualprice) FROM TABLE( CUMULATE(TABLE effective_chargeorder, DESCRIPTOR(proc_time), INTERVAL '2' MINUTES, INTERVAL '10' MINUTES)) GROUP BY window_start, window_end;
IDE报如下错误: 消费的是upsertkafka的source,由于对planner这层了解不深,不是很看的懂,请各位大佬指点~