This is an automated email from the ASF dual-hosted git repository.
sunchao pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new b8a4361 HADOOP-17270. Fix
testCompressorDecompressorWithExeedBufferLimit to c… (#2311)
b8a4361 is described below
commit b8a4361d7b6221cc524dddda1d371329877d2b02
Author: Masatake Iwasaki <[email protected]>
AuthorDate: Sun Sep 20 00:47:02 2020 +0900
HADOOP-17270. Fix testCompressorDecompressorWithExeedBufferLimit to c…
(#2311)
---
.../io/compress/TestCompressorDecompressor.java | 25 ++++++++++++----------
1 file changed, 14 insertions(+), 11 deletions(-)
diff --git
a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/compress/TestCompressorDecompressor.java
b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/compress/TestCompressorDecompressor.java
index 64e021b..43cb4df 100644
---
a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/compress/TestCompressorDecompressor.java
+++
b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/compress/TestCompressorDecompressor.java
@@ -72,20 +72,23 @@ public class TestCompressorDecompressor {
}
@Test
- public void testCompressorDecompressorWithExeedBufferLimit() {
- int BYTE_SIZE = 100 * 1024;
- byte[] rawData = generate(BYTE_SIZE);
+ public void testCompressorDecompressorWithExceedBufferLimit() {
+ // input data size greater than internal buffer size.
+ final int byteSize = 100 * 1024;
+ final int bufferSize = 64 * 1024;
+ byte[] rawData = generate(byteSize);
try {
CompressDecompressTester.of(rawData)
.withCompressDecompressPair(
- new SnappyCompressor(BYTE_SIZE + BYTE_SIZE / 2),
- new SnappyDecompressor(BYTE_SIZE + BYTE_SIZE / 2))
- .withCompressDecompressPair(new Lz4Compressor(BYTE_SIZE),
- new Lz4Decompressor(BYTE_SIZE))
-
.withTestCases(ImmutableSet.of(CompressionTestStrategy.COMPRESS_DECOMPRESS_SINGLE_BLOCK,
- CompressionTestStrategy.COMPRESS_DECOMPRESS_BLOCK,
- CompressionTestStrategy.COMPRESS_DECOMPRESS_ERRORS,
-
CompressionTestStrategy.COMPRESS_DECOMPRESS_WITH_EMPTY_STREAM))
+ new SnappyCompressor(bufferSize),
+ new SnappyDecompressor(bufferSize))
+ .withCompressDecompressPair(
+ new Lz4Compressor(bufferSize),
+ new Lz4Decompressor(bufferSize))
+ .withTestCases(ImmutableSet.of(
+ CompressionTestStrategy.COMPRESS_DECOMPRESS_BLOCK,
+ CompressionTestStrategy.COMPRESS_DECOMPRESS_ERRORS,
+ CompressionTestStrategy.COMPRESS_DECOMPRESS_WITH_EMPTY_STREAM))
.test();
} catch (Exception ex) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
