[
https://issues.apache.org/jira/browse/FLINK-20415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ingo Bürk closed FLINK-20415.
-----------------------------
Fix Version/s: 1.12.0
Resolution: Fixed
This appears to be fixed in 1.12, so I'll close this.
> 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, 1.12.0
> Reporter: Ingo Bürk
> Priority: Minor
> Fix For: 1.12.0
>
>
> 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.
>
> Note that this might also affect other descendants of Operation which contain
> table schema information (I haven't tested all of them), e.g.
> CatalogQueryOperation.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
