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:54 GMT
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 <jarcec@apache.org>
Authored: Sat Jan 18 21:38:18 2014 -0800
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
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();


Mime
View raw message