[ https://issues.apache.org/jira/browse/FLINK-22378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326222#comment-17326222 ]
Jark Wu commented on FLINK-22378: --------------------------------- This is a good question. A workaround for this can be fix the return type in {{SchemaResolver}}, or have a special {{CallContext}} (e.g. {{WatermarkCallContext}}) for watermark expressions which have access to the rowtime field (the column specified by {{WATERMARK FOR <rowtime>}}). > Type mismatch when declaring SOURCE_WATERMARK on TIMESTAMP_LTZ column > --------------------------------------------------------------------- > > Key: FLINK-22378 > URL: https://issues.apache.org/jira/browse/FLINK-22378 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / API > Reporter: Timo Walther > Priority: Major > > The following schema cannot be resolved currently: > {code} > Schema.newBuilder() > .columnByMetadata("rowtime", DataTypes.TIMESTAMP_LTZ(3)) > .watermark("rowtime", "SOURCE_WATERMARK()") > .build() > {code} > It leads to: > {code} > The watermark output type TIMESTAMP(3) is different from input time filed > type TIMESTAMP_LTZ(3). > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)