[jira] [Created] (FLINK-20415) Parsed QueryOperation does not contain watermark in schema

[Shang Yuanchun (Jira)]

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)