?????? ??????Flink SQL?????????????????

Wed, 08 Jul 2020 01:08:49 -0700 

????????????  https://issues.apache.org/jira/browse/FLINK-18523


------------------ ???????? ------------------
??????:&nbsp;"Jark Wu"<[email protected]&gt;;
????????:&nbsp;2020??7??8??(??????) ????1:26
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: ??????Flink SQL?????????????????



???? ?????? JIRA ?????? issue ??????????????~

On Wed, 8 Jul 2020 at 12:01, 1193216154 <[email protected]&gt; wrote:

&gt; &amp;nbsp; 
&amp;nbsp;Jark??flink??????????????????????????????????????????????????
&gt;
&gt;
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:&amp;nbsp;"Jark Wu"<[email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2020??7??8??(??????) ????11:48
&gt; ??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: ??????Flink SQL?????????????????
&gt;
&gt;
&gt;
&gt; ???????? partition ?????????????????? watermark ?????????? idle source 
??????????????????????
&gt; ????????????????????????????
&gt;
&gt; Best,
&gt; Jark
&gt;
&gt; On Wed, 8 Jul 2020 at 11:08, 1193216154 <[email protected]&amp;gt; wrote:
&gt;
&gt; &amp;gt; hi Jark Wu.
&gt; &amp;gt;
&gt; &amp;gt;
&gt; 
??????????table.exec.source.idle-timeout????????watermark????????????????????????watermark????????????????????????????????watermark????????????????????watermark??
&gt; &amp;gt;
&gt; 
??????????????????????????kafka??????????????????????????????????????????????????????????watermark??????????????????????????????
&gt; &amp;gt; 
????????????????eventTime????????????????????????????????waterMark(??????????),??????????????????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; 
------------------&amp;amp;nbsp;????????&amp;amp;nbsp;------------------
&gt; &amp;gt; ??????:&amp;amp;nbsp;"Jark Wu"<[email protected]&amp;amp;gt;;
&gt; &amp;gt; ????????:&amp;amp;nbsp;2020??7??7??(??????) ????6:09
&gt; &amp;gt; 
??????:&amp;amp;nbsp;"user-zh"<[email protected]&amp;amp;gt;;
&gt; &amp;gt;
&gt; &amp;gt; ????:&amp;amp;nbsp;Re: ??????Flink SQL?????????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; Hi,
&gt; &amp;gt;
&gt; &amp;gt; ?????????????????????????????????????????????? idle source
&gt; &amp;gt; ???????????????????????????? table.exec.source.idle-timeout = 10s 
????????????????????[1]
&gt; &amp;gt;
&gt; &amp;gt; Best,
&gt; &amp;gt; Jark
&gt; &amp;gt;
&gt; &amp;gt; [1]:
&gt; &amp;gt;
&gt; &amp;gt;
&gt; 
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/config.html#table-exec-source-idle-timeout
&gt; &amp;gt
&gt; 
<https://ci.apache.org/projects/flink/flink-docs-master/dev/table/config.html#table-exec-source-idle-timeout&amp;gt&gt;
&gt; ;
&gt; &amp;gt; On Tue, 7 Jul 2020 at 17:35, noake <[email protected]&amp;amp;gt; 
wrote:
&gt; &amp;gt;
&gt; &amp;gt; &amp;amp;gt; Dear All??
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt;
&gt; &amp;gt; &amp;amp;gt; ???????? ????????????Flink SQL????????????????????
&gt; &amp;gt; &amp;amp;gt; ??????????kafka???? 
?????????????????????????????????????????? ??????Flink SQL??

回复