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]> 写道： > > hi! > 版本:flink 1.10 > mysql 5.7.24 > > 需求场景是: > 使用flink SQL,读取kafka数据,和mysql的维表数据,之后进行join操作,如何配置mysql > connector,才能使维表数据修改后,flink能读取到更新后的数据进行join操作? > > 现在本地测试时,维表的DDL是: > > 但是去mysql修改了数据后,join操作还是旧数据. > > 望大神们指点方向,提前谢谢了. > > >
