You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by "René Wagner (JIRA)" <ji...@apache.org> on 2015/08/29 12:32:45 UTC

[jira] [Created] (FLUME-2778) RollingFileSink BatchSize parameter

René Wagner created FLUME-2778:
----------------------------------

             Summary: 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)