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