Eron Wright created FLINK-22700:
-----------------------------------
Summary: Propagate watermarks to Sink API
Key: FLINK-22700
URL:
https://issues.apache.org/jira/browse/FLINK-22700 Project: Flink
Issue Type: Improvement
Components: API / DataStream
Reporter: Eron Wright
Assignee: Eron Wright
Make it possible for sink functions / sink writers to propagate watermarks to external storage systems.
Note that sink functions 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 an event).
--
This message was sent by Atlassian Jira
(v8.3.4#803005)