diff --git ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorThread.java ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorThread.java index 029f882..ade7726 100644 --- ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorThread.java +++ ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorThread.java @@ -180,7 +180,9 @@ protected String findUserToRunAs(String location, Table t) throws IOException, ugi.doAs(new PrivilegedExceptionAction() { @Override public Object run() throws Exception { - FileStatus stat = fs.getFileStatus(p); + // need to use a new filesystem object here to have the correct ugi + FileSystem proxyFs = p.getFileSystem(conf); + FileStatus stat = proxyFs.getFileStatus(p); wrapper.add(stat.getOwner()); return null; }