[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16612388#comment-16612388 ]
Piotr Nowojski commented on FLINK-10327: ---------------------------------------- [~dangdangdang] ops sorry I forgot to assign myself to this one after creating. I have already a working code and I'm in the process of creating a PR for it :( > 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)