diff --git a/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java b/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java index ee6c564..95fb7e8 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java @@ -2696,7 +2696,9 @@ private static void copyFiles(final HiveConf conf, final FileSystem destFs, } else { destPath = mvFile(conf, srcP, destPath, isSrcLocal, srcFs, destFs, name, filetype); } - + if (!srcFs.getClass().equals(destFs.getClass())) { + srcGroup = destFs.getFileStatus(destPath).getGroup(); + } if (inheritPerms) { HdfsUtils.setFullFileStatus(conf, fullDestStatus, srcGroup, destFs, destPath, false); }