-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/6939/
-----------------------------------------------------------
Review request for Flume.
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
-----
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
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
