Re: Trying to understand watermark in join with FlinkSQL and late events

Hi Guillermo. ORD007 is included due to "LEFT Join" logic. The LEFT JOIN keyword returns all records from the left table, and the matching records from the right table. Watermark table configuration and "FOR SYSTEM_TIME AS OF" do not discard normal LEFT join behavior here. Best regards, Alexey

Trying to understand watermark in join with FlinkSQL and late events

I'm trying to understand how watermarks work in FlinkSQL. I’ve created the following tables: CREATE TABLE currency_rates ( currency STRING, conversion_rate STRING, update_time TIMESTAMP(3), WATERMARK FOR update_time AS update_time, PRIMARY KEY(currency) NOT ENFO