[FLINK-22700] [FLIP-167] Propagate watermarks to Sink API

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Eron Wright
• Reporter: Eron Wright
• Created: 18/May/21 22:21
• Updated: 23/Sep/21 17:56
• Resolved: 06/Jul/21 06:37

Description

Make it possible for sink functions / sink writers to propagate watermarks to external storage systems, as described in FLIP-167.

Note that sink functions already obtain the current watermark upon receiving a record.  This issue is about obtaining the watermark as it is received from upstream (i.e. not dependent on receipt of a record).

Issue Links

• links to: GitHub Pull Request #15950