[ https://issues.apache.org/jira/browse/FLINK-22700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Eron Wright updated FLINK-22700: -------------------------------- Labels: pull-request-available (was: pull-request-available stale-assigned) > [FLIP-167] 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 > Priority: Major > Labels: pull-request-available > Fix For: 1.14.0 > > > Make it possible for sink functions / sink writers to propagate watermarks to > external storage systems, as described in > [FLIP-167|https://cwiki.apache.org/confluence/display/FLINK/FLIP-167%3A+Watermarks+for+Sink+API]. > 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). -- This message was sent by Atlassian Jira (v8.3.4#803005)