另外社区中文邮件交流直接发邮件到[email protected] 
<mailto:[email protected]>就可以了,不用发[email protected] 
<mailto:[email protected]> 这个地址。


> 在 2020年7月24日,14:25,Leonard Xu <[email protected]> 写道:
> 
> Hello
> 图挂了,可以贴下DDL吗?另外你没有使用维表join语法 FOR SYSTEM_TIME AS OF[1] 
> 
> 祝好
> Leonard Xu
> [1] 
> https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/sql/queries.html#joins
>  
> <https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/sql/queries.html#joins>
>  
> 
>> 在 2020年7月24日,14:14,liunaihua521 <[email protected] 
>> <mailto:[email protected]>> 写道:
>> 
>> hi!
>>     版本:flink  1.10
>>             mysql 5.7.24
>> 
>>     需求场景是:
>>             使用flink SQL,读取kafka数据,和mysql的维表数据,之后进行join操作,如何配置mysql 
>> connector,才能使维表数据修改后,flink能读取到更新后的数据进行join操作?
>> 
>>     现在本地测试时,维表的DDL是:
>>             
>>     但是去mysql修改了数据后,join操作还是旧数据.
>> 
>> 望大神们指点方向,提前谢谢了.
>>         
>> 
>> 
> 

回复