Updated Branches: refs/heads/flume-1.5 0994eb27a -> c5745df73
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/c5745df7 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/c5745df7 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/c5745df7 Branch: refs/heads/flume-1.5 Commit: c5745df73af088c634c67e6fc5bababa4bd8b0f1 Parents: 0994eb2 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:39:24 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/c5745df7/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();
