From e98075976bf53d3e13fa31047b7274b899b37ae5 Mon Sep 17 00:00:00 2001 From: Jarek Jarcec Cecho Date: Wed, 4 Dec 2013 10:05:29 -0800 Subject: [PATCH] SQOOP-1246: HBaseImportJob should add job authtoken only if HBase is secured (Aditya Kishore via Jarek Jarcec Cecho) --- src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java b/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java index afc42991..3f18bd98 100644 --- a/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java +++ b/src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java @@ -165,7 +165,8 @@ protected void jobSetup(Job job) throws IOException, ImportException { */ 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 @@ protected void jobSetup(Job job) throws IOException, ImportException { 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) {