diff --git shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java index 4cc0008..4fc24d1 100644 --- shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java +++ shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java @@ -996,7 +996,13 @@ public HdfsEncryptionShim(URI uri, Configuration conf) throws IOException { @Override public boolean isPathEncrypted(Path path) throws IOException { - return (hdfsAdmin.getEncryptionZoneForPath(path) != null); + Path fullPath; + if (path.isAbsolute()) { + fullPath = path; + } else { + fullPath = path.getFileSystem(conf).makeQualified(path); + } + return (hdfsAdmin.getEncryptionZoneForPath(fullPath) != null); } @Override