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)