Hi everyone, I'm trying out the SQL API in flink 1.6 I first convert a data stream to a table (let's call it tableA) using tableEnv.registerDataStream, then perform queries on tableA and finally convert the result to a retract stream.
My question is: Is there a way to clean up/ remove records/expire records in tableA, by some criteria, most importantly, by TTL? Currently the table is ever increasing. Best, Chen -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
