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

batchSize for FlumeAvro non persistent manager is ignored

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: 2.2
    • Fix Version/s: None
    • Component/s: Flume Appender
    • Labels:
      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

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

                Dates

                • Created:
                  Updated:
                  Resolved: