You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/03 08:38:00 UTC
[jira] [Created] (FLINK-24143) Invalid validation error for
temporary view
Martijn Visser created FLINK-24143:
--------------------------------------
Summary: Invalid validation error for temporary view
Key: FLINK-24143
URL: https://issues.apache.org/jira/browse/FLINK-24143
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Affects Versions: 1.13.2
Reporter: Martijn Visser
Running the following SQL statement:
{code:sql}
CREATE TEMPORARY TABLE t (
id VARCHAR(2147483647) NOT NULL,
ts TIMESTAMP,
dim VARCHAR(3),
WATERMARK FOR ts AS ts - INTERVAL '60' SECOND
)
WITH (
'connector' = 'datagen'
);
CREATE TEMPORARY VIEW v AS
SELECT
TUMBLE_ROWTIME(ts, INTERVAL '60' SECOND) as window_end,
COUNT(*) as cnt
FROM t
GROUP BY
(
TUMBLE(ts, INTERVAL '60' SECOND),
dim
);
{code}
Returns: SQL parse failed. Encountered "(" at line 3, column 21.
Workarounds:
1. Remove brackets from lines 17 and 20,
OR
2. Remove line 11 - using SELECT without TEMPORARY VIEW works even with the brackets.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)