flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ruidong Li (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (FLINK-9433) SystemProcessingTimeService does not work properly
Date Thu, 09 Aug 2018 12:08:00 GMT

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

Ruidong Li edited comment on FLINK-9433 at 8/9/18 12:07 PM:
------------------------------------------------------------

How about adding a clear Thread with  a DelayQueue for AsyncWaitOperator?. [~StephanEwen]


was (Author: ruidongli):
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)

Mime
View raw message