Hi Team, Can the temporal join be achieved on Temporary views? I’m creating 2 tables using ‘kafka’ and ‘upsert-kafka’ connectors respectively, creating temporary views with some transformations on these tables. Finally joining both the temporary views. But this will be an equi-join and not temporal join. While tried to do temporal join, the client throws the exception -

[ERROR] Could not execute SQL statement. Reason:

org.apache.flink.table.api.ValidationException: Temporal Table Join requires primary key in versioned table, but no primary key can be found

. The table has primary key but when view is created on top of it, there is no primary key.

Hi , did you find a solution ? I am experiencing the same challenge.

Hi Prashant, no I am using inner join only for now.

Thanks, will attempt that . Appreciated