?????? flink ????

[liujian]

Hi:
??????Leonard????????????,??flink cdc??(??????), join ??????(debezium -> 
kafka), ????????eventTime???????????? , ??????????????eventTime  
lookup????????eventTime
1, ????????????????changlog????, ???? debezium -> kafka ????, 
??????????flink cdc????????, ????flink cdc??????????,????flink 
cdc??????????????????watermark?
2, ??????????????????????????????????????watermark??? 


??????????


------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<xbjt...@gmail.com&gt;;
????????:&nbsp;2021??5??27??(??????) ????5:14
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

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



HI??
??????????????????????????????????
?????? flink ?????? ???????? ?????? 
????????????????????????????????????????????????cache????
???????????? lookup ???????????? A join B for system time as of A.proctime on 
A.id <http://a.id/&gt; = B.id <http://b.id/&gt; ???? 
??????????????????(proctime??????????????)????????


????,
Leonard

&gt; ?? 2021??5??27????16:35??liujian <13597820...@qq.com&gt; ??????
&gt; 
&gt; ????flink 
lookup??????????,????lookup????????????????????????,?????????????????????????????
&gt; ????????????????????