This is an automated email from the ASF dual-hosted git repository. rgoers pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/flume.git
commit 6869031c6eeca4fb533307626b05f729370ed465 Merge: ddbf12f c178981 Author: Ralph Goers <rgo...@apache.org> AuthorDate: Sat Mar 26 12:50:14 2022 -0700 Merge pull request #356 from apache/FLUME-3413 FLUME-3413 3412 - Add LoadBalancingChannelSelector and Initializable .mvn/local-settings.xml | 7 - .../flume/conf/channel/ChannelSelectorType.java | 5 + .../channel/LoadBalancingChannelSelector.java | 152 +++++++++++++++++++++ .../flume/sink/AbstractSingleSinkProcessor.java | 65 +++++++++ .../apache/flume/sink/AbstractSinkProcessor.java | 2 +- .../apache/flume/sink/DefaultSinkProcessor.java | 39 +----- .../main/java/org/apache/flume/sink/NullSink.java | 8 ++ .../channel/TestLoadBalancingChannelSelector.java | 72 ++++++++++ flume-ng-doc/sphinx/FlumeDeveloperGuide.rst | 90 ++++++++++++ flume-ng-doc/sphinx/FlumeUserGuide.rst | 23 ++++ flume-ng-node/pom.xml | 12 ++ .../java/org/apache/flume/node/Application.java | 36 +++++ .../java/org/apache/flume/node/Initializable.java | 30 ++++ .../org/apache/flume/node/TestApplication.java | 67 +++++++++ .../java/org/apache/flume/sink/NullInitSink.java | 98 ++++++------- .../org/apache/flume/source/EventProcessor.java | 33 +++++ .../java/org/apache/flume/source/LocalSource.java | 89 ++++++++++++ .../src/test/resources/flume-conf-init.properties | 51 +++++++ flume-ng-node/src/test/resources/log4j2.xml | 4 +- 19 files changed, 778 insertions(+), 105 deletions(-)