[
https://issues.apache.org/jira/browse/FLUME-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14732291#comment-14732291
]
Jackey Lyu commented on FLUME-2785:
-----------------------------------
and this is the configuration for testing this issue.
agent.sources=s1
agent.channels=c1
agent.sinks=k2
agent.sources.s1.type=thrift
agent.sources.s1.bind=localhost
agent.sources.s1.port=44321
agent.sources.s1.channels=c1
#agent.sources.s1.threads= 5
agent.channels.c1.type=memory
agent.channels.c1.capacity=1000
agent.channels.c1.transactionCapacity=100
agent.sinks.k1.type=thrift
agent.sinks.k1.hostname=master
agent.sinks.k1.port=40414
agent.sinks.k1.channel=c1
agent.sinks.k2.type=null
agent.sinks.k2.channel=c1
> Add default non-zero threads value for Thrift source, to avoid
> OutofMemoryException
> -----------------------------------------------------------------------------------
>
> Key: FLUME-2785
> URL: https://issues.apache.org/jira/browse/FLUME-2785
> Project: Flume
> Issue Type: Improvement
> Components: Sinks+Sources
> Affects Versions: 1.6
> Environment: linux_64 2.6.32.57, Oracle JDK 1.7
> Reporter: Jackey Lyu
> Priority: Minor
> Labels: patch
> Fix For: notrack
>
> Attachments:
> 0001-update-the-DEFAULT_THREADS-for-configuration-threads.patch
>
> Original Estimate: 10m
> Remaining Estimate: 10m
>
> The current implementation of thrift source in
> `flume-ng-core/src/main/java/org/apache/flume/source/ThriftSource.java`,
> there is something can be done to improve the usability of thrift source.
> If users did not config the `threads` parameter for thrift source, the
> default threads number will be Integer.MAX_VALUE, which may easily cause
> OutofMemoryException.
> It's better to add a non-zero default value for it.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
