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

Sun, 09 Aug 2020 19:50:54 -0700 

??????minIdleStateRetentionTime ??
val tConfig = tableEnv.getConfig
tConfig.setIdleStateRetentionTime(Time.minutes(5), Time.minutes(10)) 
????????1.11.0??????sql??????????????????????sessionid groupby 
count(*)??????sessionid????1????????????????
????????????????????????????????????minibatch????????????????


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

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



?????? TableConfig ???? minIdleStateRetentionTime ?? maxIdleStateRetentionTime 
????

Benchao Li <[email protected]&gt; ??2020??8??10?????? ????10:36??????

&gt; Hi??
&gt;
&gt; 
??????????????????Flink??????????????SQL??????????????????????????????????????
&gt;
&gt; op <[email protected]&gt; ??2020??8??10?????? ????10:27??????
&gt;
&gt; &gt; Hi
&gt; &gt; &amp;nbsp; &amp;nbsp; ??????flink 
sql??????????????????????????????????????????
&gt; &gt; &amp;nbsp; val config = tableConfig.getConfiguration()
&gt; &gt; &amp;nbsp; 
&amp;nbsp;&amp;nbsp;config.setString("table.exec.mini-batch.enabled",
&gt; &gt; "true")
&gt; &gt; &amp;nbsp;
&gt; &amp;nbsp;&amp;nbsp;config.setString("table.exec.mini-batch.allow-latency",
&gt; &gt; "5s")
&gt; &gt; &amp;nbsp; 
&amp;nbsp;&amp;nbsp;config.setString("table.exec.mini-batch.size", "20")
&gt; &gt;
&gt; 
????????FsStateBackend????RocksDBStateBackend??????????????????????????????????????checkpoint????????????????????????
&gt; &gt; 
??????????????????????????????????????????checkpoint????????????????????????????????????????????????????????????????????
&gt;
&gt;
&gt;
&gt; --
&gt;
&gt; Best,
&gt; Benchao Li
&gt;

回复