[
https://issues.apache.org/jira/browse/FLUME-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13860909#comment-13860909
]
Hari Shreedharan commented on FLUME-2275:
-----------------------------------------
This line causes a compiler warning that can be fixed pretty easily by using
new ConcurrentLinkedQueue<LocalMorphlineInterceptor>:
{code}
private final ConcurrentLinkedQueue<LocalMorphlineInterceptor> pool = new
ConcurrentLinkedQueue();
{code}
Also, we should uses interfaces for instances than concrete implementations -
so we should use Queue<LocalMorphlineInterceptor> pool = ...
> Improve scalability of MorphlineInterceptor under contention
> ------------------------------------------------------------
>
> Key: FLUME-2275
> URL: https://issues.apache.org/jira/browse/FLUME-2275
> Project: Flume
> Issue Type: Improvement
> Components: Sinks+Sources
> Affects Versions: v1.4.0
> Reporter: wolfgang hoschek
> Assignee: wolfgang hoschek
> Fix For: v1.4.1, v1.5.0
>
> Attachments: FLUME-2275-v3.patch
>
>
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)