[
https://issues.apache.org/jira/browse/FLUME-2778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14954588#comment-14954588
]
Gonzalo Herreros commented on FLUME-2778:
-----------------------------------------
Since the other properties are looked under "sink.", it seems more logical at
this stage to update the documentation (or maybe check in both places to
support people that configured it according to the documentation)
> 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)
