osdir.com

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[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)