[ 
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)

Reply via email to