(DEPRECATED) Apache Flink User Mailing List archive.

Re: Flink SQL continuous join checkpointing

Posted by Taras Moisiuk on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-SQL-continuous-join-checkpointing-tp40267p40277.html

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 the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.