Re: How to Join a dimension table in flink sql

Hi XiangWei, Unfortunately, it's not possible for the Flink SQL API to join a stream with a common dataset now. As a workaround, if the table is just a tiny one, you can achieve a inner/left outer join with the user defined table functions

Re: How to Join a dimension table in flink sql

Hi XiangWei, Currently one could implement a udtf to achieve that. (see https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/table/udfs. html#table-functions) BTW, this udtf should carefully dealing with the connections to database server(s), and enable caching if possible can reduce se

How to Join a dimension table in flink sql

Hi all, Is it possible to join records read from a kafka stream with one(or more) dimension tables which are saved as mysql table using flink streaming sql.