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 <hshreedha...@apache.org> Authored: Mon Dec 9 20:02:01 2013 -0800 Committer: Hari Shreedharan <hshreedha...@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.");
