Queue size should only be used for monitoring/operational purposes and
to estimate optimal PortContext.QUEUE_CAPACITY value. It is not used in
Reservoir implementation to pull tuples from the Reservoir.
Based on the current performance testing I plan to change default value
of PortContext.QUEUE_CAPACITY from 1024 to 1<<19 (still need to do my
homework and see where PortContext.QUEUE_CAPACITY is used).
Thank you,
Vlad
On 11/18/15 11:23, Chetan Narsude (cnarsude) wrote:
What are we doing for size() being inaccurate with spsc?
On 11/18/15, 8:55 AM, "vrozov" <[email protected]> wrote:
Github user vrozov commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/173#issuecomment-157777
188
There are 3 applications running on the dev cluster:
SpscArrayQueueReservoir around 25 million tuples/s
CircularBufferReservoir - around 10 million tuples/s
ArrayBlockingQueueReservoir - around 1.5 million tuples/s
---
If your project is set up for it, you can reply to this email and have
your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working,
please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
