flink1.10 sql state 聚合函数 窗口统计,状态越来越大,无法自动清理问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink1.10 sql state 聚合函数 窗口统计,状态越来越大,无法自动清理问题

zhuyuping
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/