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

Wed, 23 Sep 2020 20:19:50 -0700 

????benchao??????????????????????config??????????????????????????sql??????????????


 




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??9??23??(??????) ????5:22
??????:&nbsp;"user-zh"<[email protected]&gt;;

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



????????Blink planner??TUMBLE window????????????????????????????state 
retention[1]??????????late????????
??????allow lateness??????????????????min retention time

[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/query_configuration.html#idle-state-retention-time

ang <[email protected]&gt; ??2020??9??23?????? ????4:24??????

&gt; hi????????????????????????
&gt; ??????????flink 
sql????????kafka??????????????????????????????????????????event
&gt; 
time????????5s??????????????????????????????????????????5s??????????waterwark??
&gt; WATERMARK FOR ts AS ts&amp;nbsp; - INTERVAL '5' SECODND
&gt; 
??????????????????5s????????????????????????????????????????????????????????????????????datastream
 api????????????allowed
&gt; lateness??????????????sql??????????????????
&gt;
&gt;
&gt; Flink????1.10.1
&gt; &amp;nbsp;



-- 

Best,
Benchao Li

回复