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