Ruidong Li created FLINK-9433:
---------------------------------
Summary: SystemProcessingTimeService does not work properly
Key: FLINK-9433
URL: https://issues.apache.org/jira/browse/FLINK-9433
Project: Flink
Issue Type: Improvement
Components: Streaming
Reporter: Ruidong Li
Assignee: Ruidong Li
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)
