GitHub user majorendre opened a pull request:
https://github.com/apache/flume/pull/212
WIP FLUME-3246 Validate flume configuration to prevent larger source batcâ¦
â¦h size than the channel transaction capacity
The loadSources() method seemed like an appropriate place to check this.
Added 2 new interfaces for getting the transaction capacity and the batch
size fields. The check is only done for channels that implement the
TransactioCapacitySupported interface and sources that implement the
BatchSizeSupported interface.
There is a new unit test case that I used for testing.
TODOs:
Add the BatchSizeSupported interface to all the sources that handle batch
size.
Check how this works when reloading configuration.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/majorendre/flume FLUME-3246
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flume/pull/212.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #212
----
commit b548e41f4299e45a3b9e1f74c080203c4c301774
Author: emajor <emajor@...>
Date: 2018-06-19T12:54:50Z
FLUME-3246 Validate flume configuration to prevent larger source batch size
than the channel transaction capacity
----
---
