这个应该不是 bug，如果用代码写，在定义了事件时间的时候，也是要加水印的，否则无法触发窗口的 trigger
guaishushu1...@163.com <guaishushu1...@163.com> 于2020年5月15日周五 下午5:36写道： > insert into t_report_realtime_fangxin2_order1 > > SELECT date_format(TUMBLE_END(w_ts, INTERVAL '60' SECOND),'yyyy-MM-dd') as > summary_date, > date_format(TUMBLE_END(w_ts, INTERVAL '60' SECOND), 'yyyy-MM-dd hh') as > summary_hour, > date_format(TUMBLE_END(w_ts, INTERVAL '60' SECOND), 'yyyy-MM-dd hh:mm') as > summary_minute, > 'all' as city1_id, > 'all' as cate3_id, > count(DISTINCT(pay_order_id)) as order_num_dj3 > FROM ( > select w_ts, > JsonIndexOf(ArrayIndexOf(w_data, 0), 'city_id') as city1_id, > JsonIndexOf(ArrayIndexOf(w_data, 0), 'three_level_cate_id') as cate3_id, > JsonIndexOf(ArrayIndexOf(w_data, 0), 'pay_order_id') as pay_order_id > from hdp_lbg_huangye_payorder_binlog > ) > GROUP BY TUMBLE(w_ts, INTERVAL '60' SECOND) > ; > > 定义了eventime属性，但是算子并没有watermarks 导致数据一致不能输出 > > ------------------------------ > guaishushu1...@163.com >
