|
@@ -26,6 +26,7 @@ import org.apache.hadoop.io.compress.snappy.SnappyCompressor;
|
|
|
import org.apache.hadoop.io.compress.snappy.SnappyDecompressor;
|
|
|
import org.apache.hadoop.io.compress.zlib.BuiltInZlibDeflater;
|
|
|
import org.apache.hadoop.io.compress.zlib.BuiltInZlibInflater;
|
|
|
+import org.apache.hadoop.test.GenericTestUtils;
|
|
|
import org.junit.Test;
|
|
|
import com.google.common.collect.ImmutableSet;
|
|
|
|
|
@@ -66,7 +67,8 @@ public class TestCompressorDecompressor {
|
|
|
.test();
|
|
|
|
|
|
} catch (Exception ex) {
|
|
|
- fail("testCompressorDecompressor error !!!" + ex);
|
|
|
+ GenericTestUtils.assertExceptionContains(
|
|
|
+ "testCompressorDecompressor error !!!", ex);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -88,7 +90,8 @@ public class TestCompressorDecompressor {
|
|
|
.test();
|
|
|
|
|
|
} catch (Exception ex) {
|
|
|
- fail("testCompressorDecompressorWithExeedBufferLimit error !!!" + ex);
|
|
|
+ GenericTestUtils.assertExceptionContains(
|
|
|
+ "testCompressorDecompressorWithExeedBufferLimit error !!!", ex);
|
|
|
}
|
|
|
}
|
|
|
|