SQOOP-616 HBase import/export is not working on non secure cluster where

security is available

(Jarek Jarcec Cecho via Cheolsoo Park)

src/java/org/apache/sqoop/mapreduce/HBaseImportJob.java

@@ -145,32 +145,39 @@ protected void jobSetup(Job job) throws IOException, ImportException {
     // Add authentication token to the job if we're running on secure cluster.
     //
     // We're currently supporting HBase version 0.90 that do not have security
-    // patches which means that it do not have required method
+    // patches which means that it do not have required methods
-    // "obtainAuthTokenForJob".
+    // "isSecurityEnabled" and "obtainAuthTokenForJob".
     //
-    // We're using reflection API to see if this method is available and call
+    // We're using reflection API to see if those methods are available and call
-    // it only if it's present.
+    // them only if they are present.
     //
     // After we will remove support for HBase 0.90 we can simplify the code to
     // following code fragment:
     /*
     try {
-      User user = User.getCurrent();
+      if (User.isSecurityEnabled()) {
-      user.obtainAuthTokenForJob(conf, job);
+        User user = User.getCurrent();
+        user.obtainAuthTokenForJob(conf, job);
+      }
     } catch(InterruptedException ex) {
       throw new ImportException("Can't get authentication token", ex);
     }
     */
     try {
-      // Get the method
+      // Get method isSecurityEnabled
+      Method isSecurityEnabled = User.class.getMethod("isSecurityEnabled");
+
+      // Get method obtainAuthTokenForJob
       Method obtainAuthTokenForJob = User.class.getMethod(
         "obtainAuthTokenForJob", Configuration.class, Job.class);
 
       // Get current user
       User user = User.getCurrent();
 
-      // Obtain security token if needed (it's no-op on non secure cluster)
+      // Obtain security token if needed
-      obtainAuthTokenForJob.invoke(user, conf, job);
+      if((Boolean)isSecurityEnabled.invoke(null)) {
+        obtainAuthTokenForJob.invoke(user, conf, job);
+      }
     } catch (NoSuchMethodException e) {
       LOG.info("It seems that we're running on HBase without security"
         + " additions. Security additions will not be used during this job.");