You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by ja...@apache.org on 2014/01/16 20:59:37 UTC
git commit: FLUME-2301. Update HBaseSink tests to reflect sink
returning backoff only on empty batches
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 <ja...@apache.org>
Authored: Thu Jan 16 11:58:39 2014 -0800
Committer: Jarek Jarcec Cecho <ja...@apache.org>
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);