Hi Leonard, Thank you for answer, in fact I used regular join because my interval condition was based on wrong column.
I extended my join with attribute column condition and it solved the
problem:
...
FROM table_fx fx
LEFT JOIN table_v v ON v.active = fx.instrument_active_id
AND v.kafka_time BETWEEN fx.kafka_time - INTERVAL '10' MINUTE
AND fx.kafka_time
...
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
