[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Flink sql joined with dimtable from mysql

It was not super clean on what you did. But from your description, the join
was not correct initially because existing MySQL data was not seen by Flink
yet. Later when updates are seen by Flink, the result will be correct. A
better place for such question is probably on the user mailing list.


On Tue, Nov 13, 2018 at 6:08 PM yelun <986463030@xxxxxx> wrote:

> 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
> beginning, but the latter stream can be joined correctly. So I want to ask
> that is there any good way to make real-time stream can join with mysql
> data which has loaded and supporting dynamicly loading mysql data into
> memory once each hour. Thanks a lot.