You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tajo.apache.org by jh...@apache.org on 2016/02/05 06:10:36 UTC

tajo git commit: TAJO-858: Support for hadoop kerberos authentication in Tajo.

Repository: tajo
Updated Branches:
  refs/heads/master fc55d2c6c -> 2fc99117f


TAJO-858: Support for hadoop kerberos authentication in Tajo.

Signed-off-by: Jinho Kim <jh...@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/tajo/repo
Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/2fc99117
Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/2fc99117
Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/2fc99117

Branch: refs/heads/master
Commit: 2fc99117f5fe45f0d8cdc862601cba639da27956
Parents: fc55d2c
Author: Min Zhou <co...@gmail.com>
Authored: Fri Feb 5 14:07:59 2016 +0900
Committer: Jinho Kim <jh...@apache.org>
Committed: Fri Feb 5 14:07:59 2016 +0900

----------------------------------------------------------------------
 CHANGES                                              |  3 +++
 .../java/org/apache/tajo/storage/FileScanner.java    | 15 +--------------
 2 files changed, 4 insertions(+), 14 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tajo/blob/2fc99117/CHANGES
----------------------------------------------------------------------
diff --git a/CHANGES b/CHANGES
index c655f0a..16f7f33 100644
--- a/CHANGES
+++ b/CHANGES
@@ -104,6 +104,9 @@ Release 0.12.0 - unreleased
 
   BUG FIXES
 
+    TAJO-858: Support for hadoop kerberos authentication in Tajo.
+    (Min Zhou via jinho)
+
     TAJO-2066: Fix TestJoinOnPartitionedTables.testPartialFilterPushDown failure.
     (jinho)
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/2fc99117/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileScanner.java
----------------------------------------------------------------------
diff --git a/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileScanner.java b/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileScanner.java
index 33f1d04..94e07e5 100644
--- a/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileScanner.java
+++ b/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileScanner.java
@@ -102,20 +102,7 @@ public abstract class FileScanner implements Scanner {
   }
 
   public static FileSystem getFileSystem(TajoConf tajoConf, Path path) throws IOException {
-    String tajoUser = tajoConf.getVar(TajoConf.ConfVars.USERNAME);
-    FileSystem fs;
-    if(tajoUser != null) {
-      try {
-        fs = FileSystem.get(path.toUri(), tajoConf, tajoUser);
-      } catch (InterruptedException e) {
-        LOG.warn("Occur InterruptedException while FileSystem initiating with user[" + tajoUser + "]");
-        fs = FileSystem.get(path.toUri(), tajoConf);
-      }
-    } else {
-      fs = FileSystem.get(path.toUri(), tajoConf);
-    }
-
-    return fs;
+    return FileSystem.get(path.toUri(), tajoConf);
   }
 
   @Override