Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Can't support temporal table join #58

Open
zhiyuan192shine opened this issue May 27, 2020 · 0 comments
Open

Can't support temporal table join #58

zhiyuan192shine opened this issue May 27, 2020 · 0 comments

Comments

@zhiyuan192shine
Copy link

zhiyuan192shine commented May 27, 2020

SQL example:

CREATE VIEW v_inout_flow AS
SELECT tb.park_code,
       tb.park_name,
       tb.city_code,
       tb.city_name,
       ta.status,
       ta.event_time
  FROM ods_inout_flow AS ta
  JOIN dim_park FOR SYSTEM_TIME AS OF ta.proctime AS tb
    ON ta.org_code = tb.org_code;

The exception is:

Caused by: org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "`dim_park`" at line 3, column 20.
Was expecting one of:
    "TABLE" ...
    "(" ...

	at org.apache.flink.table.planner.calcite.CalciteParser.parse(CalciteParser.java:50)
	at org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:64)
	at org.apache.flink.table.api.internal.TableEnvironmentImpl.sqlQuery(TableEnvironmentImpl.java:464)
	at com.ververica.flink.table.gateway.operation.CreateViewOperation.lambda$execute$0(CreateViewOperation.java:57)
	at com.ververica.flink.table.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:204)
	at com.ververica.flink.table.gateway.operation.CreateViewOperation.execute(CreateViewOperation.java:56)
	... 45 more
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant