Hi, guoliubin
Please ignore my previous answer, I mixed your question with an another one, I
post the right temporal join sql syntax here.
SELECT [column_list]
FROM table1 [AS ]
[LEFT] JOIN table2 FOR SYSTEM_TIME AS OF table1.{ proctime | rowtime } [AS
]
ON table1.column-name1 = table2.column-na
Hi, guoliubin
Sorry for the late reply, I think the example in release note has a minor typo
error which missed the ‘AS’ keyword.
SELECT
o.order_id,
o.order_time,
o.amount * r.currency_rate AS amount,
r.currency
FROM orders AS o, latest_rates FOR SYSTEM_TIME AS OF o.order_time
I just try to follow the example list in the page
https://flink.apache.org/news/2020/12/10/release-1.12.0.html#table-apisql-support-for-temporal-table-joins-in-sql
Unfortunately when I try to upload the python file to flink cluster, the error
occured:
py4j.protocol.Py4JJavaError: An error occu