[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Shimin Yang reassigned FLINK-10327: ----------------------------------- Assignee: Shimin Yang > Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction > --------------------------------------------------------------------------- > > Key: FLINK-10327 > URL: https://issues.apache.org/jira/browse/FLINK-10327 > Project: Flink > Issue Type: New Feature > Components: Streaming > Reporter: Piotr Nowojski > Assignee: Shimin Yang > Priority: Major > > Currently {{CoProcessFunction}} can not react to changes watermark > advancement. By passing {{processWatermark}} calls to function we would give > a way to perform some actions on watermark advancement, like state clean up > or emitting some results after accumulating some data. -- This message was sent by Atlassian JIRA (v7.6.3#76005)