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/

回复