[FLUME-2778] RollingFileSink BatchSize parameter

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Assignee: Unassigned
• Reporter: René Wagner
• Created: 29/Aug/15 10:32
• Updated: 20/Oct/15 12:04

Description

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.