[
https://issues.apache.org/jira/browse/FLINK-23162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mans Singh updated FLINK-23162:
-------------------------------
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
{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.
was:
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.
> 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
> 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)
