Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Flume >> mail # dev >> Review Request: Flume-1541: Implement a SinkSelector for LoadBalancingSinkProcessor that includes failover mechanics


Copy link to this message
-
Re: Review Request: Flume-1541: Implement a SinkSelector for LoadBalancingSinkProcessor that includes failover mechanics

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/6939/
-----------------------------------------------------------

(Updated Sept. 6, 2012, 8:24 a.m.)
Review request for Flume.
Changes
-------

Fixed whitespace and config name
Description
-------

Added a callback to the SinkSelector interface to inform selectors of sink failures, adding a noop stub to the abstract source so existing selectors don't need changes.

The new selector maintains counts of sequential failures as well as times for intended recovery and last failure time, which it uses to decide whether or not a sink should be added to the returned iterator. The iterator is generated in such a way that the round robin remains balanced.
This addresses bug FLUME-1541.
    https://issues.apache.org/jira/browse/FLUME-1541
Diffs (updated)
-----

  flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkSelector.java 63397a5
  flume-ng-core/src/main/java/org/apache/flume/sink/LoadBalancingSinkProcessor.java 18d4509
  flume-ng-core/src/test/java/org/apache/flume/sink/TestLoadBalancingSinkProcessor.java 1e9c94e
  flume-ng-doc/sphinx/FlumeUserGuide.rst ffed72b

Diff: https://reviews.apache.org/r/6939/diff/
Testing
-------

Added 3 new tests to verify that dynamic rebalancing is done, that the sink becomes available again after timeout, and that the timeout increases with sequential failures

All tests pass
Thanks,

Juhani Connolly