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

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.13.1
• Fix Version/s: 1.14.0, 1.13.2
• Component/s: Documentation, Table SQL / API
• Labels: doc example pull-request-available sql
• Assignee: Mans Singh
• Reporter: Mans Singh
• Created: 26/Jun/21 21:28
• Updated: 23/Sep/21 17:52
• Resolved: 27/Jun/21 05:15

Description

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

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 (
...
);

When it is executed in the flink sql client it throws an exception:

[ERROR] Could not execute SQL statement. Reason:
org.apache.calcite.sql.validate.SqlValidatorException: Unknown identifier 'time_ltz'

The create table works if the expression uses ts as the argument while declaring time_ltz.

Issue Links

• links to: GitHub Pull Request #16301