[prev in list] [next in list] [prev in thread] [next in thread] 

List:       flume-commits
Subject:    git commit: FLUME-2209. AsyncHBaseSink will never recover if the column family does not exists for t
From:       hshreedharan () apache ! org
Date:       2013-12-10 4:06:03
Message-ID: 91805a3f511e476ba0c9a59654264c18 () git ! apache ! org
[Download RAW message or body]

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.");


[prev in list] [next in list] [prev in thread] [next in thread]