With Idle state retention having below configuration (Same heap space issue)
With time-windowed join (Records gets missed out and duplicated based on the timeinterval I push badips)
SELECT K.* FROM KafkaSource AS K, BadIP AS B WHERE K.sourceip = B.bad_ip AND B.b_proctime BETWEEN K.k_proctime - INTERVAL '20' MINUTE AND K.k_proctime + INTERVAL '5' MINUTE
I have tried Temporal functions - It is working fine
I was really wishing to make it work with idle state and time window join. Could you please check the configuration and query.
Please let me know if any other details are required