flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "守护" <346531...@qq.com>
Subject 回复: blinkSQL架构会自动清理过期的state吗
Date Thu, 12 Sep 2019 06:35:33 GMT
下面是我要执行的代码,麻烦帮看一下:


&nbsp; &nbsp; tableEnv.registerDataStream("testCountTable", waterMarkStream, 'curuserid,'timelong,'rowtime.rowtime)
&nbsp; &nbsp;&nbsp;
&nbsp; &nbsp; val result = tableEnv.sqlQuery(s"SELECT COUNT(0) as pv,COUNT(distinct
curuserid)" +
&nbsp; &nbsp; &nbsp; s" as uv,TUMBLE_END(rowtime, INTERVAL '10' MINUTE) FROM testCountTable
GROUP BY TUMBLE(rowtime, INTERVAL '10' MINUTE)")


&nbsp; &nbsp; val dsRow: DataStream[Row] = tableEnv.toAppendStream[Row](result)


&nbsp; &nbsp; val data=dsRow.map(w =&gt; {
&nbsp; &nbsp; &nbsp; val StrArrary = w.toString.split(",")
&nbsp; &nbsp; &nbsp; val str="{\"pv\":"+"\""+StrArrary(0)+"\""+",\"uv\":"+"\""+StrArrary(1)+"\""+",\"rowtime\":"+"\""+StrArrary(2)+"\""+"}"
&nbsp; &nbsp; &nbsp; str
&nbsp; &nbsp; })
&nbsp; &nbsp; data.print()





------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"Jark Wu"<imjark@gmail.com&gt;;
发送时间:&nbsp;2019年9月12日(星期四) 中午12:51
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;Re: blinkSQL架构会自动清理过期的state吗



Hi,
能提供下 SQL 么?

blink sql 的 window 理论上是会自动清理的。 

&gt; 在 2019年9月11日,18:56,守护 <346531110@qq.com&gt; 写道:
&gt; 
&gt; 社区各位大佬:
&gt; 请教一个问题,flink1.9中使用blink SQL语句,设置时间窗口,state存储方式选择FSStateBackend,现在发现State一直在增大,过了窗口后也没有删除过期state,是blink架构就不支持窗口自动清理state吗,还是我哪使用的不对,我测试1.9的flinkSQL是不会有这个问题的。
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message