[
https://issues.apache.org/jira/browse/APEXCORE-402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15267843#comment-15267843
]
ASF GitHub Bot commented on APEXCORE-402:
-----------------------------------------
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/286#discussion_r61828415
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/AbstractReservoir.java ---
@@ -47,7 +49,7 @@
{
private static final Logger logger =
LoggerFactory.getLogger(AbstractReservoir.class);
static final String reservoirClassNameProperty =
"com.datatorrent.stram.engine.Reservoir";
- private static final int USE_SPSC_CAPACITY = 8 * 1024;
+ private static final int USE_SPSC_CAPACITY = 64 * 1024;
--- End diff --
As SpscArrayBlockingQueueReservoir provides larger throughtput compared to
ArrayBlockingQueueReservoir, it exceeds throughput of SpscReservoir for larger
queue capacity.
> Provide SpscArrayQueue based implementation that uses Condition to notify
> publishing thread on not full condition
> -----------------------------------------------------------------------------------------------------------------
>
> Key: APEXCORE-402
> URL: https://issues.apache.org/jira/browse/APEXCORE-402
> Project: Apache Apex Core
> Issue Type: Sub-task
> Reporter: Vlad Rozov
> Assignee: Vlad Rozov
> Fix For: 3.4.0
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
