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

Posted to issues@flink.apache.org by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/08/09 11:18:00 UTC

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

    [ https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574704#comment-16574704 ] 

Ruidong Li commented on FLINK-9433:
-----------------------------------

How about add a clear thread with Java DelayQueue for AsyncWaitOperator. [~StephanEwen]

> 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
>         Attachments: log.txt
>
>
> 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)