[FLINK-22378] Type mismatch when declaring SOURCE_WATERMARK on TIMESTAMP_LTZ column

• Type: Sub-task
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 1.14.0, 1.13.1
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 20/Apr/21 15:23
• Updated: 28/May/21 11:05
• Resolved: 27/Apr/21 12:57

Description

The following schema cannot be resolved currently:

Schema.newBuilder()
    .columnByMetadata("rowtime", DataTypes.TIMESTAMP_LTZ(3))
    .watermark("rowtime", "SOURCE_WATERMARK()")
    .build()

It leads to:

The watermark output type TIMESTAMP(3) is different from input time filed type TIMESTAMP_LTZ(3).

Issue Links

• links to: GitHub Pull Request #15730