geode-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (GEODE-2745) The AsyncEventQueueImpl waitUntilFlushed method waits longer than it should for events to be flushed
Date Thu, 13 Apr 2017 17:18:42 GMT

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

ASF subversion and git services commented on GEODE-2745:
--------------------------------------------------------

Commit f13da788c8b2d2315581c451154f8e5410b764bc in geode's branch refs/heads/feature/GEODE-2632
from [~lhughesgodfrey]
[ https://git-wip-us.apache.org/repos/asf?p=geode.git;h=f13da78 ]

GEODE-2745: waitUntilFlushed method waits longer than it should

- Added getter in BucketRegionQueue for latestQueuedKey
- WaitUntilBucketRegionQueueFlushedCallable constructor now gets/maintains the BucketRegionQueue.latestQueuedKey


> 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