Repository: tajo Updated Branches: refs/heads/master fc55d2c6c -> 2fc99117f
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/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 <[email protected]> Authored: Fri Feb 5 14:07:59 2016 +0900 Committer: Jinho Kim <[email protected]> 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
