http://apache-flink.147419.n8.nabble.com/flink1-10-1-1-11-1-sql-group-td5491.html跟这个问题类似
Filesystem rocksdb 都试过,rowtime proctime 窗口统计都试过。
CREATE VIEW cpd_expo_feature_collect_view as select
imei,incrmentFeatureCollect(CAST(serverTime AS INT),adId) as feature from
dwd_oth_ads_appstore_exposure_process_view
group by TUMBLE (proctime, INTERVAL '10' SECOND),imei;
--
Sent from:
http://apache-flink.147419.n8.nabble.com/