flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject git commit: FLUME-2303. HBaseSink tests can fail based on order of execution
Date Sun, 19 Jan 2014 05:39:10 GMT
Updated Branches:
  refs/heads/trunk 68ba5cf71 -> b8c550168


FLUME-2303. HBaseSink tests can fail based on order of execution

(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/b8c55016
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/b8c55016
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/b8c55016

Branch: refs/heads/trunk
Commit: b8c5501683244df156ff6d70a72a12bac131ed8f
Parents: 68ba5cf
Author: Jarek Jarcec Cecho <jarcec@apache.org>
Authored: Sat Jan 18 21:38:18 2014 -0800
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
Committed: Sat Jan 18 21:38:18 2014 -0800

----------------------------------------------------------------------
 .../src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java    | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flume/blob/b8c55016/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 f2bba31..068f543 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
@@ -145,6 +145,7 @@ public class TestHBaseSink {
   @Test
   public void testThreeEvents() throws Exception {
     testUtility.createTable(tableName.getBytes(), columnFamily.getBytes());
+    ctx.put("batchSize", "3");
     HBaseSink sink = new HBaseSink(testUtility.getConfiguration());
     Configurables.configure(sink, ctx);
     Channel channel = new MemoryChannel();


Mime
View raw message