diff --git a/src/test/java/io/airlift/compress/v2/HadoopNative.java b/src/test/java/io/airlift/compress/v2/HadoopNative.java index 17b0146b..14bd122d 100644 --- a/src/test/java/io/airlift/compress/v2/HadoopNative.java +++ b/src/test/java/io/airlift/compress/v2/HadoopNative.java @@ -13,12 +13,6 @@ */ package io.airlift.compress.v2; -import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.io.compress.CompressionCodec; -import org.apache.hadoop.io.compress.CompressionCodecFactory; -import org.apache.hadoop.io.compress.GzipCodec; -import org.apache.hadoop.io.compress.zlib.ZlibDecompressor; -import org.apache.hadoop.io.compress.zlib.ZlibFactory; import org.apache.hadoop.util.NativeCodeLoader; import java.io.File; @@ -51,8 +45,6 @@ public static synchronized void requireHadoopNative() loadLibrary("gplcompression"); loadLibrary("lzo2"); - requireNativeZlib(); - loaded = true; } catch (Throwable t) { @@ -61,24 +53,6 @@ public static synchronized void requireHadoopNative() } } - private static void requireNativeZlib() - { - Configuration conf = new Configuration(); - if (!ZlibFactory.isNativeZlibLoaded(conf)) { - throw new RuntimeException("native zlib is not loaded"); - } - - CompressionCodecFactory factory = new CompressionCodecFactory(conf); - CompressionCodec codec = factory.getCodecByClassName(GzipCodec.class.getName()); - if (codec == null) { - throw new RuntimeException("failed to load GzipCodec"); - } - org.apache.hadoop.io.compress.Decompressor decompressor = codec.createDecompressor(); - if (!(decompressor instanceof ZlibDecompressor)) { - throw new RuntimeException("wrong gzip decompressor: " + decompressor.getClass().getName()); - } - } - private static void setStatic(Field field, Object value) throws IllegalAccessException { diff --git a/src/test/java/io/airlift/compress/v2/zstd/TestZstdCodec.java b/src/test/java/io/airlift/compress/v2/zstd/TestZstdCodec.java index 9475bf74..6ccb251d 100644 --- a/src/test/java/io/airlift/compress/v2/zstd/TestZstdCodec.java +++ b/src/test/java/io/airlift/compress/v2/zstd/TestZstdCodec.java @@ -21,8 +21,6 @@ import io.airlift.compress.v2.HadoopCodecDecompressor; import io.airlift.compress.v2.thirdparty.ZstdJniCompressor; import io.airlift.compress.v2.thirdparty.ZstdJniDecompressor; -import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.io.compress.CompressionCodec; import org.junit.jupiter.api.Test; import java.io.IOException; @@ -30,15 +28,6 @@ class TestZstdCodec extends AbstractTestCompression { - private final CompressionCodec verifyCodec; - - TestZstdCodec() - { - org.apache.hadoop.io.compress.ZStandardCodec codec = new org.apache.hadoop.io.compress.ZStandardCodec(); - codec.setConf(new Configuration()); - this.verifyCodec = codec; - } - @Override protected boolean isMemorySegmentSupported() {