Updated Branches: refs/heads/trunk cf2ac3713 -> 9a4f04766
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/9a4f0476 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/9a4f0476 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/9a4f0476 Branch: refs/heads/trunk Commit: 9a4f047668eb56895fb4bf5c1ee3e5dd6add8601 Parents: cf2ac37 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:58:39 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/9a4f0476/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);
