Hi Leonard, I have just realized that "last_value" operator does not work since it produces updates if the right side changes. I just need the current state in the moment I receive a message on the left side. It is indeed a lookup which O want to perform and not a real join.
Since my topic only has one partition the first option will also not work for me. Following your comments I guess I need to reconsider the design of my problem. Best, Torben -----Ursprüngliche Nachricht----- Von: Leonard Xu [mailto:xbjt...@gmail.com] Gesendet: Dienstag, 19. Januar 2021 10:36 An: Barth, Torben <t.ba...@fraport.de> Cc: user@flink.apache.org Betreff: Re: Pyflink Join with versioned view / table Hi, Torben Happy to hear you address your problem, the first option can resolve the situation that partial partitions of the Kafka topic did not receive data, but if all partitions didn't receive data, the watermark won't be pushed forward, and the temporal join won't be triggered. Otherwise, we may get unexpected join result because after we output the join result the change from the versioned table side happens. Best, Leonard Fraport AG Frankfurt Airport Services Worldwide, 60547 Frankfurt am Main, Sitz der Gesellschaft: Frankfurt am Main, Amtsgericht Frankfurt am Main: HRB 7042, Umsatzsteuer-Identifikationsnummer: DE 114150623, Vorsitzender des Aufsichtsrates: Michael Boddenberg – Hessischer Minister der Finanzen; Vorstand: Dr. Stefan Schulte (Vorsitzender), Anke Giesen, Michael Müller, Dr. Pierre Dominique Prümm, Dr. Matthias Zieschang
