|
@@ -48,6 +48,7 @@ import org.apache.hadoop.hdfs.protocol.BlockType;
|
|
|
import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.StartupOption;
|
|
|
import org.apache.hadoop.io.erasurecode.ECSchema;
|
|
|
import org.apache.hadoop.ipc.RemoteException;
|
|
|
+import org.apache.hadoop.util.NativeCodeLoader;
|
|
|
import org.junit.Assert;
|
|
|
|
|
|
import org.apache.hadoop.fs.permission.PermissionStatus;
|
|
@@ -74,6 +75,7 @@ import org.apache.hadoop.hdfs.util.MD5FileUtils;
|
|
|
import org.apache.hadoop.test.GenericTestUtils;
|
|
|
import org.apache.hadoop.test.PathUtils;
|
|
|
import org.apache.hadoop.util.Time;
|
|
|
+import org.junit.Assume;
|
|
|
import org.junit.Test;
|
|
|
|
|
|
import static org.junit.Assert.assertArrayEquals;
|
|
@@ -99,6 +101,13 @@ public class TestFSImage {
|
|
|
setCompressCodec(conf, "org.apache.hadoop.io.compress.DefaultCodec");
|
|
|
setCompressCodec(conf, "org.apache.hadoop.io.compress.GzipCodec");
|
|
|
setCompressCodec(conf, "org.apache.hadoop.io.compress.BZip2Codec");
|
|
|
+ }
|
|
|
+
|
|
|
+ @Test
|
|
|
+ public void testNativeCompression() throws IOException {
|
|
|
+ Assume.assumeTrue(NativeCodeLoader.isNativeCodeLoaded());
|
|
|
+ Configuration conf = new Configuration();
|
|
|
+ conf.setBoolean(DFSConfigKeys.DFS_IMAGE_COMPRESS_KEY, true);
|
|
|
setCompressCodec(conf, "org.apache.hadoop.io.compress.Lz4Codec");
|
|
|
}
|
|
|
|