geode-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (GEODE-2745) The AsyncEventQueueImpl waitUntilFlushed method waits longer than it should for events to be flushed
Date Wed, 12 Apr 2017 20:46:41 GMT

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

ASF GitHub Bot commented on GEODE-2745:
---------------------------------------

Github user ladyVader closed the pull request at:

    https://github.com/apache/geode/pull/448


> The AsyncEventQueueImpl waitUntilFlushed method waits longer than it should for events
to be flushed
> ----------------------------------------------------------------------------------------------------
>
>                 Key: GEODE-2745
>                 URL: https://issues.apache.org/jira/browse/GEODE-2745
>             Project: Geode
>          Issue Type: Bug
>          Components: wan
>            Reporter: Barry Oglesby
>            Assignee: Shelley Lynn Hughes-Godfrey
>             Fix For: 1.2.0
>
>
> With the changes to waitUntilFlushed to process 10 buckets at a time, if events are happening
while waitUntilFlushed is in progress, then all the buckets after the first 10 will have processed
more than it should before returning.
> If the update rate is causing the queue to always contain 113000 events, and the events
are spread evenly across the buckets, each bucket will have 1000 events to wait for. The first
10 buckets will wait for their 1000 events. When those have been processed, the next 10 buckets
will wait for their 1000 events starting from that point, but they've already processed 1000
events. So, these buckets will actually wait for 2000 events to be processed before returning.
This pattern continues until all the buckets are done.
> The WaitUntilBucketRegionQueueFlushedCallable needs to track not only the BucketRegionQueue
but also the latestQueuedKey.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message