flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hshreedha...@apache.org
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 GMT
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 <hshreedharan@apache.org>
Authored: Mon Dec 9 20:02:01 2013 -0800
Committer: Hari Shreedharan <hshreedharan@apache.org>
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.");


Mime
View raw message