Return-Path: X-Original-To: apmail-flume-commits-archive@www.apache.org Delivered-To: apmail-flume-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id DD22210A5E for ; Sun, 19 Jan 2014 05:39:56 +0000 (UTC) Received: (qmail 13798 invoked by uid 500); 19 Jan 2014 05:39:56 -0000 Delivered-To: apmail-flume-commits-archive@flume.apache.org Received: (qmail 13767 invoked by uid 500); 19 Jan 2014 05:39:56 -0000 Mailing-List: contact commits-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flume.apache.org Delivered-To: mailing list commits@flume.apache.org Received: (qmail 13760 invoked by uid 99); 19 Jan 2014 05:39:55 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 19 Jan 2014 05:39:55 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 020401049A; Sun, 19 Jan 2014 05:39:54 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: jarcec@apache.org To: commits@flume.apache.org Message-Id: <773f9fc8c0e8428aac0cd768a79971e2@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: git commit: FLUME-2303. HBaseSink tests can fail based on order of execution Date: Sun, 19 Jan 2014 05:39:54 +0000 (UTC) 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 Authored: Sat Jan 18 21:38:18 2014 -0800 Committer: Jarek Jarcec Cecho 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();