Then common way is to read in the cdc .writing generic operator wont be easy .
On Wed, Jan 23, 2019 at 12:45 PM Manjusha Vuyyuru <vmanjusha....@gmail.com> wrote: > But 'JDBCInputFormat' will exit once its done reading all data.I need > something like which keeps polling to mysql and fetch if there are any > updates or changes. > > Thanks, > manju > > On Wed, Jan 23, 2019 at 7:10 AM Zhenghua Gao <doc...@gmail.com> wrote: > >> Actually flink-connectors/flink-jdbc module provided a JDBCInputFormat to >> read data from a database. >> u can have a try. >> >> >> >> -- >> Sent from: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >> > -- *Cheers * *Puneet Kinra* *Mobile:+918800167808 | Skype : puneet.ki...@customercentria.com <puneet.ki...@customercentria.com>* *e-mail :puneet.ki...@customercentria.com <puneet.ki...@customercentria.com>*