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)