[FLINK-21899] Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 22/Mar/21 03:01
• Updated: 23/Mar/21 04:34
• Resolved: 23/Mar/21 04:34

Description

The SOURCE_WATERMARK function doesn't have concrete implementation. The eval() function should throw a meaningful exception message to indicate users the function should only be used in DDL to generate a watermark preserved from source system.

Issue Links

• links to: GitHub Pull Request #15326