Repository: tajo Updated Branches: refs/heads/branch-0.11.2 ae1cd8cf2 -> ad177cbb6
TAJO-858: Support for hadoop kerberos authentication in Tajo. Signed-off-by: Jinho Kim <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/tajo/repo Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/ad177cbb Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/ad177cbb Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/ad177cbb Branch: refs/heads/branch-0.11.2 Commit: ad177cbb67be65a2f536df001650ecb1541fa360 Parents: ae1cd8c Author: Min Zhou <[email protected]> Authored: Fri Feb 5 14:12:56 2016 +0900 Committer: Jinho Kim <[email protected]> Committed: Fri Feb 5 14:12:56 2016 +0900 ---------------------------------------------------------------------- CHANGES | 5 +++++ .../java/org/apache/tajo/storage/FileScanner.java | 15 +-------------- 2 files changed, 6 insertions(+), 14 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/ad177cbb/CHANGES ---------------------------------------------------------------------- diff --git a/CHANGES b/CHANGES index db930ff..d6c3b68 100644 --- a/CHANGES +++ b/CHANGES @@ -6,6 +6,11 @@ Release 0.11.2 - unreleased TAJO-2070: Remove unnecessarily version property in maven pom. (jinho) + BUG FIXES + + TAJO-858: Support for hadoop kerberos authentication in Tajo. + (Min Zhou via jinho) + Release 0.11.1 - released http://git-wip-us.apache.org/repos/asf/tajo/blob/ad177cbb/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
