Hi yelun,
Currently, there are no direct ways to dynamically load data and do join in
Flink-SQL, as a workaround you can implement your logic with an udtf. In
the udtf, you can load the data into a cache and update it according to
your requirement.
Best, Hequn
On Wed, Nov 14, 2018 at 10:34 AM ye
hi,
I want to use flink sql to left join static dimension table from mysql
currently, so I converted the mysql table into data stream to join with
datastream which has converted to flink table. While I found that the real-time
stream data is not joined correctly with mysql data at the beginnin
