[
https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16489006#comment-16489006
]
Stephan Ewen commented on FLINK-9433:
-------------------------------------
Can you share the design how you want to fix this?
Ideally, we can still retain the property that only one timer is scheduled per
operator, and that only one thread exists per task.
> 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)
