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/19 06:39:10 UTC
git commit: FLUME-2303. HBaseSink tests can fail based on order of
execution
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 <ja...@apache.org>
Authored: Sat Jan 18 21:38:18 2014 -0800
Committer: Jarek Jarcec Cecho <ja...@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();