[ 
https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Stephan Ewen updated FLINK-9433:
--------------------------------
    Issue Type: Bug  (was: Improvement)

> SystemProcessingTimeService does not work properly
> --------------------------------------------------
>
>                 Key: FLINK-9433
>                 URL: https://issues.apache.org/jira/browse/FLINK-9433
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>            Reporter: Ruidong Li
>            Assignee: Ruidong Li
>            Priority: Critical
>
> 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
(v7.6.3#76005)

Reply via email to