diff --git a/shims/0.20S/src/main/java/org/apache/hadoop/hive/shims/Hadoop20SShims.java b/shims/0.20S/src/main/java/org/apache/hadoop/hive/shims/Hadoop20SShims.java index 6c6ccbc..c747d1f 100644 --- a/shims/0.20S/src/main/java/org/apache/hadoop/hive/shims/Hadoop20SShims.java +++ b/shims/0.20S/src/main/java/org/apache/hadoop/hive/shims/Hadoop20SShims.java @@ -672,8 +672,9 @@ public StoragePolicyShim getStoragePolicyShim(FileSystem fs) { public boolean runDistCp(Path src, Path dst, Configuration conf) throws IOException { DistCpOptions options = new DistCpOptions(Collections.singletonList(src), dst); - options.setSkipCRC(true); options.setSyncFolder(true); + options.setSkipCRC(true); + options.preserve(FileAttribute.BLOCKSIZE); try { DistCp distcp = new DistCp(conf, options); distcp.execute(); diff --git a/shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java b/shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java index 3292cb3..2dc7cef 100644 --- a/shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java +++ b/shims/0.23/src/main/java/org/apache/hadoop/hive/shims/Hadoop23Shims.java @@ -1213,8 +1213,9 @@ public void setStoragePolicy(Path path, StoragePolicyValue policy) public boolean runDistCp(Path src, Path dst, Configuration conf) throws IOException { DistCpOptions options = new DistCpOptions(Collections.singletonList(src), dst); - options.setSkipCRC(true); options.setSyncFolder(true); + options.setSkipCRC(true); + options.preserve(FileAttribute.BLOCKSIZE); try { DistCp distcp = new DistCp(conf, options); distcp.execute();