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)
