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

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

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




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??8??10??(??????) ????2:13
??????:&nbsp;"user-zh"<[email protected]&gt;;

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



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


&gt; -----????????-----
&gt; ??????: op <[email protected]&gt;
&gt; ????????: 2020-08-10 10:50:08 (??????)
&gt; ??????: user-zh <[email protected]&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;
 <[email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2020??8??10??(??????) ????10:44
&gt; ??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt; 
&gt; ????:&amp;nbsp;Re: flink sql????????????
&gt; 
&gt; 
&gt; 
&gt; ?????? TableConfig ???? minIdleStateRetentionTime ?? 
maxIdleStateRetentionTime ????
&gt; 
&gt; Benchao Li <[email protected]&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 <[email protected]&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

回复