hi grouby count(*)??????
------------------ ???????? ------------------ ??????: "user-zh" <ld...@zju.edu.cn>; ????????: 2020??8??10??(??????) ????2:13 ??????: "user-zh"<user-zh@flink.apache.org>; ????: Re: ?????? flink sql???????????? Hi, ??????????minibatch,??????aggregate?????????? > -----????????----- > ??????: op <520075...@qq.com> > ????????: 2020-08-10 10:50:08 (??????) > ??????: user-zh <user-zh@flink.apache.org> > ????: > ????: ?????? flink sql???????????? > > ??????minIdleStateRetentionTime ?? > val tConfig = tableEnv.getConfig > tConfig.setIdleStateRetentionTime(Time.minutes(5), Time.minutes(10)) > ????????1.11.0??????sql??????????????????????sessionid groupby count(*)??????sessionid????1???????????????? > ????????????????????????????????????minibatch???????????????? > > > ------------------&nbsp;????????&nbsp;------------------ > ??????: "user-zh" <godfre...@gmail.com&gt;; > ????????:&nbsp;2020??8??10??(??????) ????10:44 > ??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;; > > ????:&nbsp;Re: flink sql???????????? > > > > ?????? TableConfig ???? minIdleStateRetentionTime ?? maxIdleStateRetentionTime ???? > > Benchao Li <libenc...@apache.org&gt; ??2020??8??10?????? ????10:36?????? > > &gt; Hi?? > &gt; > &gt; ??????????????????Flink??????????????SQL?????????????????????????????????????? > &gt; > &gt; op <520075...@qq.com&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; ------------------------------ ?????? ???????? ?????? ???????????????????? ????????217 ????????????????????????38?????????????????? Tel??18867547281