Re: upsert-kafka to do temporal table joins

2020-12-16 Thread Leonard Xu
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

Re: upsert-kafka to do temporal table joins

2020-12-16 Thread Leonard Xu
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

upsert-kafka to do temporal table joins

2020-12-14 Thread guoliubi...@foxmail.com
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