You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/05/24 12:43:00 UTC

[jira] [Created] (FLINK-9433) SystemProcessingTimeService does not work properly

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)