Updated Branches: refs/heads/flume-1.5 ee75bc57c -> 4bb265834
FLUME-2301. Update HBaseSink tests to reflect sink returning backoff only on empty batches (Hari Shreedharan via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/4bb26583 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/4bb26583 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/4bb26583 Branch: refs/heads/flume-1.5 Commit: 4bb2658348f836e0e03b14f5a949a05663b54bfe Parents: ee75bc5 Author: Jarek Jarcec Cecho <[email protected]> Authored: Thu Jan 16 11:58:39 2014 -0800 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Thu Jan 16 11:59:22 2014 -0800 ---------------------------------------------------------------------- .../src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/4bb26583/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java b/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java index f41bf53..f2bba31 100644 --- a/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java +++ b/flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java @@ -200,10 +200,8 @@ public class TestHBaseSink { tx.commit(); tx.close(); int count = 0; - Status status = Status.READY; - while(status != Status.BACKOFF){ + while(sink.process() != Status.BACKOFF){ count++; - status = sink.process(); } sink.stop(); Assert.assertEquals(2, count);
