[
https://issues.apache.org/jira/browse/FLUME-1198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13278974#comment-13278974
]
[email protected] commented on FLUME-1198:
------------------------------------------------------
bq. On 2012-05-18 16:56:42, Brock Noland wrote:
bq. >
/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkSelector.java,
line 37
bq. > <https://reviews.apache.org/r/5161/diff/2/?file=109548#file109548line37>
bq. >
bq. > remove codegen
done.
bq. On 2012-05-18 16:56:42, Brock Noland wrote:
bq. >
/trunk/flume-ng-core/src/test/java/org/apache/flume/sink/TestLoadBalancingSinkProcessor.java,
line 247
bq. > <https://reviews.apache.org/r/5161/diff/2/?file=109553#file109553line247>
bq. >
bq. > We want to be checking s1..s0 as opposed to s1 and s3?
thanks for catching this Brock! Will fix it right away.
- Arvind
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/5161/#review7973
-----------------------------------------------------------
On 2012-05-18 08:02:10, Arvind Prabhakar wrote:
bq.
bq. -----------------------------------------------------------
bq. This is an automatically generated e-mail. To reply, visit:
bq. https://reviews.apache.org/r/5161/
bq. -----------------------------------------------------------
bq.
bq. (Updated 2012-05-18 08:02:10)
bq.
bq.
bq. Review request for Flume and Juhani Connolly.
bq.
bq.
bq. Summary
bq. -------
bq.
bq. 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.
bq.
bq. Also, this processor accepts implementations of sink selectors which can
be used to route the load into various sinks.
bq.
bq.
bq. This addresses bug FLUME-1198.
bq. https://issues.apache.org/jira/browse/FLUME-1198
bq.
bq.
bq. Diffs
bq. -----
bq.
bq.
/trunk/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkProcessorType.java
1339941
bq.
/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java
PRE-CREATION
bq.
/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkSelector.java
PRE-CREATION
bq.
/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/FailoverSinkProcessor.java
1339941
bq.
/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/LoadBalancingSinkProcessor.java
PRE-CREATION
bq.
/trunk/flume-ng-core/src/test/java/org/apache/flume/sink/FixedOrderSelector.java
PRE-CREATION
bq.
/trunk/flume-ng-core/src/test/java/org/apache/flume/sink/SinkProcessorFactoryTest.java
1339941
bq.
/trunk/flume-ng-core/src/test/java/org/apache/flume/sink/TestLoadBalancingSinkProcessor.java
PRE-CREATION
bq.
bq. Diff: https://reviews.apache.org/r/5161/diff
bq.
bq.
bq. Testing
bq. -------
bq.
bq. Introduced new tests and ran all existing tests.
bq.
bq.
bq. Thanks,
bq.
bq. Arvind
bq.
bq.
> Implement a load-balancing sink processor
> -----------------------------------------
>
> Key: FLUME-1198
> URL: https://issues.apache.org/jira/browse/FLUME-1198
> Project: Flume
> Issue Type: Improvement
> Reporter: Arvind Prabhakar
> Assignee: Arvind Prabhakar
> Fix For: v1.2.0
>
> Attachments: BalancingSinkProcessor.java, FLUME-1198-2.patch
>
>
> A load-balancing sink processor that can distribute the load over multiple
> sinks. The distribution of load could be round/robin or random, preferably
> configurable to support both.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
