You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Ingo Bürk (Jira)" <ji...@apache.org> on 2020/11/30 07:34:00 UTC
[jira] [Created] (FLINK-20415) Parsed QueryOperation does not
contain watermark in schema
Ingo Bürk created FLINK-20415:
---------------------------------
Summary: Parsed QueryOperation does not contain watermark in schema
Key: FLINK-20415
URL: https://issues.apache.org/jira/browse/FLINK-20415
Project: Flink
Issue Type: Improvement
Components: Table SQL / API
Affects Versions: 1.11.2
Reporter: Ingo Bürk
A parsed QueryOperation (e.g. from Parser#parse) does not contain the watermark information in its schema (QueryOperation#getTableSchema). The information does appear to be available in the calcite tree.
This can be reproduced by creating a simple table with a watermark, e.g.:
{code:java}
CREATE TABLE x (
id INT,
ts TIMESTAMP(3),
WATERMARK FOR ts AS ts
) WITH (
'connector' = 'datagen'
){code}
… and then parsing a statement like `SELECT * FROM x`.
API-wise, QueryOperation is currently marked internal (and as such this is only marked as an improvement), but TableSchema is public-evolving, and if QueryOperation was as well this could be seen as a bug instead.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)