You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Mans Singh (Jira)" <ji...@apache.org> on 2021/06/26 21:29:00 UTC

[jira] [Created] (FLINK-23162) Create table uses time_ltz in the column name and it's expression which results in exception

Mans Singh created FLINK-23162:
----------------------------------

             Summary: 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, Examples, Table SQL / Client
    Affects Versions: 1.13.1
            Reporter: Mans Singh
             Fix For: 1.14.0


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
{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)