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 server's pressure.
2018-01-15 18:11 GMT+08:00 XiangWei Huang <xw.huang...@gmail.com>: > 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. >
