----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/5161/ -----------------------------------------------------------
Review request for Flume and Juhani Connolly. Summary ------- Added a load-balancing sink processor that uses default round-robin policy to select sinks from the group. In case of failure, it skips the sink and goes to the next. Can be configured to use random distribution of load instead of default round-robin semantics. Also, this processor accepts implementations of sink selectors which can be used to route the load into various sinks. Diffs ----- /trunk/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkProcessorType.java 1339941 /trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java PRE-CREATION /trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkSelector.java PRE-CREATION /trunk/flume-ng-core/src/main/java/org/apache/flume/sink/FailoverSinkProcessor.java 1339941 /trunk/flume-ng-core/src/main/java/org/apache/flume/sink/LoadBalancingSinkProcessor.java PRE-CREATION /trunk/flume-ng-core/src/test/java/org/apache/flume/sink/FixedOrderSelector.java PRE-CREATION /trunk/flume-ng-core/src/test/java/org/apache/flume/sink/SinkProcessorFactoryTest.java 1339941 /trunk/flume-ng-core/src/test/java/org/apache/flume/sink/TestLoadBalancingSinkProcessor.java PRE-CREATION Diff: https://reviews.apache.org/r/5161/diff Testing ------- Introduced new tests and ran all existing tests. Thanks, Arvind
