sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject sqoop git commit: SQOOP-2128: HBaseImportJob should close connection from HBaseAdmin to HBase
Date Tue, 24 Feb 2015 06:17:03 GMT
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 <jarcec@apache.org>
Authored: Mon Feb 23 22:16:25 2015 -0800
Committer: Jarek Jarcec Cecho <jarcec@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);


Mime
View raw message