[LOG4J2-1053] batchSize for FlumeAvro non persistent manager is ignored

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 2.2
• Component/s: Flume Appender
• Assignee: Unassigned
• Reporter: Siva Kotipalli
• Created: 14/Jun/15 16:20
• Updated: 14/Jun/15 23:22
• Resolved: 14/Jun/15 23:22

Description

The batchSize parameter that is included during creation of RpcClient is only used in case of appenBatch method and not for append method.
Kindly refer to the documentation below.
http://flume.apache.org/releases/content/1.5.0/apidocs/org/apache/flume/api/AbstractRpcClient.html#getBatchSize()

In the existing unit test testBatch(), the batch size is given as 10 and check on the channel also done after populating 10 events, instead if you populate only 5 events, the events should not be transferred to the channel as batchSize is 10 and we need to get error on Assert.assertNotNull, which doesnt happen.
I had done some tweaks on FlumeAvroManager and tested with appendBatch, where the batchSize parameter is properly identified by rpc client.

Issue Links

• duplicates: LOG4J2-1044 batchSize doesnt work for flume avro manager