You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ja...@apache.org on 2015/02/24 07:17:03 UTC
sqoop git commit: SQOOP-2128: HBaseImportJob should close connection
from HBaseAdmin to HBase
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 <ja...@apache.org>
Authored: Mon Feb 23 22:16:25 2015 -0800
Committer: Jarek Jarcec Cecho <ja...@apache.org>
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);