Hello, I am streaming mongodb oplog using kafka and flink and want to join multiple tables using flink table api but i have some concerns like is it possible to join streamed tables in flink and if yes then please provide me some example of stream join using table API.
I gone through your dynamic table api doc. it is quit interesting but haven't found any example tutorial how to implement dynamic table. I have tried to implement table api join using pojo class but it is giving org.apache.flink.table.api.TableException: Cannot generate a valid execution plan for the given query ----------------------------------------------- *Amol Suryawanshi* Java Developer am...@iprogrammer.com *iProgrammer Solutions Pvt. Ltd.* *Office 103, 104, 1st Floor Pride Portal,Shivaji Housing Society, Bahiratwadi,Near Hotel JW Marriott, Off Senapati Bapat Road, Pune - 411016, MH, INDIA.**Phone: +91 9689077510 | Skype: amols_iprogrammer* www.iprogrammer.com <sac...@iprogrammer.com> ------------------------------------------------
