另外社区中文邮件交流直接发邮件到[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操作还是旧数据. >> >> 望大神们指点方向,提前谢谢了. >> >> >> >
