From 8c14c7b5bb770cf12597d7b8f81f0a2ff11135f4 Mon Sep 17 00:00:00 2001 From: Andrew Purtell Date: Thu, 29 May 2014 18:39:44 -0700 Subject: [PATCH] HBASE-11259 Compression.java different compressions load system classpath differently causing errors (Enoch Hsu) --- .../org/apache/hadoop/hbase/io/compress/Compression.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/io/compress/Compression.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/io/compress/Compression.java index edc6a76329f..da20836b27b 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/io/compress/Compression.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/io/compress/Compression.java @@ -123,8 +123,7 @@ public final class Compression { private CompressionCodec buildCodec(Configuration conf) { try { Class externalCodec = - ClassLoader.getSystemClassLoader() - .loadClass("com.hadoop.compression.lzo.LzoCodec"); + getClassLoaderForCodec().loadClass("com.hadoop.compression.lzo.LzoCodec"); return (CompressionCodec) ReflectionUtils.newInstance(externalCodec, new Configuration(conf)); } catch (ClassNotFoundException e) { @@ -208,8 +207,7 @@ public final class Compression { private CompressionCodec buildCodec(Configuration conf) { try { Class externalCodec = - ClassLoader.getSystemClassLoader() - .loadClass("org.apache.hadoop.io.compress.SnappyCodec"); + getClassLoaderForCodec().loadClass("org.apache.hadoop.io.compress.SnappyCodec"); return (CompressionCodec) ReflectionUtils.newInstance(externalCodec, conf); } catch (ClassNotFoundException e) {