?????? ?????? flink sql????????????

Mon, 10 Aug 2020 01:49:51 -0700 

hi
grouby count(*)??????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<ld...@zju.edu.cn&gt;;
????????:&nbsp;2020??8??10??(??????) ????2:13
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: ?????? flink sql????????????



Hi,
??????????minibatch,??????aggregate??????????


&gt; -----????????-----
&gt; ??????: op <520075...@qq.com&gt;
&gt; ????????: 2020-08-10 10:50:08 (??????)
&gt; ??????: user-zh <user-zh@flink.apache.org&gt;
&gt; ????: 
&gt; ????: ?????? flink sql????????????
&gt; 
&gt; ??????minIdleStateRetentionTime ??
&gt; val tConfig = tableEnv.getConfig
&gt; tConfig.setIdleStateRetentionTime(Time.minutes(5), Time.minutes(10)) 
&gt; ????????1.11.0??????sql??????????????????????sessionid groupby 
count(*)??????sessionid????1????????????????
&gt; ????????????????????????????????????minibatch????????????????
&gt; 
&gt; 
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; 
??????:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 
"user-zh"&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 <godfre...@gmail.com&amp;gt;;
&gt; ????????:&amp;nbsp;2020??8??10??(??????) ????10:44
&gt; ??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&gt; 
&gt; ????:&amp;nbsp;Re: flink sql????????????
&gt; 
&gt; 
&gt; 
&gt; ?????? TableConfig ???? minIdleStateRetentionTime ?? 
maxIdleStateRetentionTime ????
&gt; 
&gt; Benchao Li <libenc...@apache.org&amp;gt; ??2020??8??10?????? 
????10:36??????
&gt; 
&gt; &amp;gt; Hi??
&gt; &amp;gt;
&gt; &amp;gt; 
??????????????????Flink??????????????SQL??????????????????????????????????????
&gt; &amp;gt;
&gt; &amp;gt; op <520075...@qq.com&amp;gt; ??2020??8??10?????? ????10:27??????
&gt; &amp;gt;
&gt; &amp;gt; &amp;gt; Hi
&gt; &amp;gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; ??????flink 
sql??????????????????????????????????????????
&gt; &amp;gt; &amp;gt; &amp;amp;nbsp; val config = 
tableConfig.getConfiguration()
&gt; &amp;gt; &amp;gt; &amp;amp;nbsp; 
&amp;amp;nbsp;&amp;amp;nbsp;config.setString("table.exec.mini-batch.enabled",
&gt; &amp;gt; &amp;gt; "true")
&gt; &amp;gt; &amp;gt; &amp;amp;nbsp;
&gt; &amp;gt; 
&amp;amp;nbsp;&amp;amp;nbsp;config.setString("table.exec.mini-batch.allow-latency",
&gt; &amp;gt; &amp;gt; "5s")
&gt; &amp;gt; &amp;gt; &amp;amp;nbsp; 
&amp;amp;nbsp;&amp;amp;nbsp;config.setString("table.exec.mini-batch.size", "20")
&gt; &amp;gt; &amp;gt;
&gt; &amp;gt; 
????????FsStateBackend????RocksDBStateBackend??????????????????????????????????????checkpoint????????????????????????
&gt; &amp;gt; &amp;gt; 
??????????????????????????????????????????checkpoint????????????????????????????????????????????????????????????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; --
&gt; &amp;gt;
&gt; &amp;gt; Best,
&gt; &amp;gt; Benchao Li
&gt; &amp;gt;


------------------------------
??????

???????? ?????? ???????????????????? ????????217
????????????????????????38??????????????????
Tel??18867547281

回复