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)
