Re: Flink sql joined with dimtable from mysql

2018-11-13 Thread yelun
Thanks for your guidance. > 在 2018年11月13日,下午9:49,Xiaowei Jiang 写道: > > 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

Re: Flink sql joined with dimtable from mysql

2018-11-13 Thread Xiaowei Jiang
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. Xiao

Flink sql joined with dimtable from mysql

2018-11-13 Thread yelun
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 beginni