Repository: sqoop Updated Branches: refs/heads/trunk 35ad630d7 -> 1c3d0efe2
SQOOP-2128: HBaseImportJob should close connection from HBaseAdmin to HBase (Esteban Gutierrez via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/1c3d0efe Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/1c3d0efe Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/1c3d0efe Branch: refs/heads/trunk Commit: 1c3d0efe2f77b08fab5d1ea0a06e1b4ae2d95d14 Parents: 35ad630 Author: Jarek Jarcec Cecho <[email protected]> Authored: Mon Feb 23 22:16:25 2015 -0800 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Mon Feb 23 22:16:25 2015 -0800 ---------------------------------------------------------------------- src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/1c3d0efe/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java b/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java index 39c2765..523d0a7 100644 --- a/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java +++ b/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java @@ -247,6 +247,10 @@ public class HBaseImportJob extends DataDrivenImportJob { } } + // Make sure we close the connection to HBA, this is only relevant in + // unit tests + admin.close(); + // Make sure HBase libraries are shipped as part of the job. TableMapReduceUtil.addDependencyJars(job); TableMapReduceUtil.addDependencyJars(conf, HTable.class);
