Flink SQL - IntervalJoin doesn't support consuming update and delete - trying to deduplicate rows

Hi! I'm using Flink SQL to do an interval join. Rows in one of the tables are not unique. I'm fine using either the first or last row. When I try to deduplicate and then interval join, I get

Re: Flink reads data from JDBC table only on startup

For your case, you should use a temporal table join syntax, and set up a refresh TTL for the RHS join cache. Taras Moisiuk 于2020年12月28日周一 下午7:21写道： > Hi Danny, > > I use regular join and it looks like: > > SELECT > ... > FROM *dynamic_kafka_table* k > JOIN *jdbc_table* j ON k.id = j.k_id > > > S