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 1AE8910995 for ; Tue, 10 Dec 2013 04:06:06 +0000 (UTC) Received: (qmail 44951 invoked by uid 500); 10 Dec 2013 04:06:04 -0000 Delivered-To: apmail-flume-commits-archive@flume.apache.org Received: (qmail 44890 invoked by uid 500); 10 Dec 2013 04:06:04 -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 44883 invoked by uid 99); 10 Dec 2013 04:06:03 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Dec 2013 04:06:03 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 5D3CC903204; Tue, 10 Dec 2013 04:06:03 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: hshreedharan@apache.org To: commits@flume.apache.org Message-Id: <91805a3f511e476ba0c9a59654264c18@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: git commit: FLUME-2209. AsyncHBaseSink will never recover if the column family does not exists for the first start. Date: Tue, 10 Dec 2013 04:06:03 +0000 (UTC) Updated Branches: refs/heads/flume-1.5 209169bb5 -> a0e29ebd7 FLUME-2209. AsyncHBaseSink will never recover if the column family does not exists for the first start. (Ashish Paliwal via Hari Shreedharan) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/a0e29ebd Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/a0e29ebd Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/a0e29ebd Branch: refs/heads/flume-1.5 Commit: a0e29ebd792e5dd5867364cda919ba6a776e45be Parents: 209169b Author: Hari Shreedharan Authored: Mon Dec 9 20:02:01 2013 -0800 Committer: Hari Shreedharan Committed: Mon Dec 9 20:05:27 2013 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/a0e29ebd/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java b/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java index 0545554..5316cd6 100644 --- a/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java +++ b/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java @@ -445,6 +445,8 @@ public class AsyncHBaseSink extends AbstractSink implements Configurable { } if(fail.get()){ sinkCounter.incrementConnectionFailedCount(); + client.shutdown(); + client = null; throw new FlumeException( "Could not start sink. " + "Table or column family does not exist in Hbase.");