[ https://issues.apache.org/jira/browse/FLINK-23162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu reassigned FLINK-23162: ------------------------------- Assignee: Mans Singh > Create table uses time_ltz in the column name and it's expression which > results in exception > --------------------------------------------------------------------------------------------- > > Key: FLINK-23162 > URL: https://issues.apache.org/jira/browse/FLINK-23162 > Project: Flink > Issue Type: Improvement > Components: Documentation, Table SQL / API > Affects Versions: 1.13.1 > Reporter: Mans Singh > Assignee: Mans Singh > Priority: Minor > Labels: doc, example, pull-request-available, sql > Fix For: 1.14.0 > > Original Estimate: 10m > Remaining Estimate: 10m > > The create table example in > [https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/concepts/time_attributes/] > uses the `time_ltz` in it's declaration and expression > {quote}CREATE TABLE user_actions ( > user_name STRING, > data STRING, > ts BIGINT, > time_ltz AS TO_TIMESTAMP_LTZ(time_ltz, 3), > – declare time_ltz as event time attribute and use 5 seconds delayed > watermark strategy > WATERMARK FOR time_ltz AS time_ltz - INTERVAL '5' SECOND > ) WITH ( > ... > ); > {quote} > When it is executed in the flink sql client it throws an exception: > {quote}[ERROR] Could not execute SQL statement. Reason: > org.apache.calcite.sql.validate.SqlValidatorException: Unknown identifier > 'time_ltz' > {quote} > The create table works if the expression uses ts as the argument while > declaring time_ltz. -- This message was sent by Atlassian Jira (v8.3.4#803005)