[
https://issues.apache.org/jira/browse/FLUME-2778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14965017#comment-14965017
]
René Wagner commented on FLUME-2778:
------------------------------------
In almost all other properties, batchSize parameter resides on root too. So it
would be more consistent to keep it on root.
> RollingFileSink BatchSize parameter
> -----------------------------------
>
> Key: FLUME-2778
> URL: https://issues.apache.org/jira/browse/FLUME-2778
> Project: Flume
> Issue Type: Bug
> Reporter: René Wagner
> Priority: Minor
>
> According to documentation, RollingFileSink batchSize parameter sits on root.
> a1.sinks.k1.batchSize = 1
> According to source code, batchSize parameter is consumed from sink.batchSize.
> batchSize = context.getInteger("sink.batchSize", defaultBatchSize);
> aka:
> a1.sinks.k1.sink.batchSize = c1
> I assume, source code looks at the wrong place.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
