[ https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek closed FLINK-9433. ----------------------------------- Resolution: Abandoned I'm closing this as "Abandoned", since there is no more activity and the code base has moved on quite a bit. Please re-open this if you feel otherwise and work should continue. The code base has moved to a new mailbox model for the Task, so things changed quite a bit. > SystemProcessingTimeService does not work properly > -------------------------------------------------- > > Key: FLINK-9433 > URL: https://issues.apache.org/jira/browse/FLINK-9433 > Project: Flink > Issue Type: Bug > Components: API / DataStream > Reporter: Ruidong Li > Assignee: Ruidong Li > Priority: Critical > Attachments: log.txt > > > if (WindowOperator --> AsyncWaitOperator) chained together, when the queue > of AsyncWaitOperator is full and timeTrigger of WindowOperator is triggered > to call collect(), it will wait until the queue of AsyncWaitOperator is not > full, at the moment, the timeTrigger of AsyncWaitOperator will not be > triggered because the SystemProcessingTimeService has only one capacity. -- This message was sent by Atlassian Jira (v8.3.4#803005)