Uploaded image for project: 'Log4j 2'
  1. Log4j 2
  2. LOG4J2-1053

batchSize for FlumeAvro non persistent manager is ignored

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Duplicate
    • 2.2
    • None
    • Flume Appender
    • None

    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.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              siva.bitsNbytes Siva Kotipalli
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: