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 <[email protected]> Authored: Sat Jan 18 21:38:18 2014 -0800 Committer: Jarek Jarcec Cecho <[email protected]> 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();
