Updated Branches: refs/heads/trunk 5f7013eae -> e98075976
SQOOP-1246: HBaseImportJob should add job authtoken only if HBase is secured (Aditya Kishore 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/e9807597 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/e9807597 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/e9807597 Branch: refs/heads/trunk Commit: e98075976bf53d3e13fa31047b7274b899b37ae5 Parents: 5f7013e Author: Jarek Jarcec Cecho <[email protected]> Authored: Wed Dec 4 10:05:29 2013 -0800 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Wed Dec 4 10:05:29 2013 -0800 ---------------------------------------------------------------------- src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/e9807597/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 afc4299..3f18bd9 100644 --- a/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java +++ b/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java @@ -165,7 +165,8 @@ public class HBaseImportJob extends DataDrivenImportJob { */ try { // Get method isSecurityEnabled - Method isSecurityEnabled = User.class.getMethod("isSecurityEnabled"); + Method isHBaseSecurityEnabled = User.class.getMethod( + "isHBaseSecurityEnabled", Configuration.class); // Get method obtainAuthTokenForJob Method obtainAuthTokenForJob = User.class.getMethod( @@ -175,7 +176,7 @@ public class HBaseImportJob extends DataDrivenImportJob { User user = User.getCurrent(); // Obtain security token if needed - if ((Boolean)isSecurityEnabled.invoke(null)) { + if ((Boolean)isHBaseSecurityEnabled.invoke(null, conf)) { obtainAuthTokenForJob.invoke(user, conf, job); } } catch (NoSuchMethodException e) {
