Re: How do i load mysql data into task

2020-11-19 Thread Arvid Heise
Hi Jiazhi, you can use a rich function and query all static data in open [1] as you'd do it in Java if you want to load the data into main memory. If you want to dynamically query the database (enriching a record), you should use Async IO instead. [2] Alternatively, you can also use the data sour

How do i load mysql data into task

2020-11-18 Thread ?g???U?[????
Hi all      How to use DataStream to load mysql data into the memory of flink task when the task is initialized? Please give me a demo. Thanks, Jiazhi