HADOOP-19339. OutofBounds Exception due to assumption about buffer si…

…ze in BlockCompressorStream. Contributed by ConfX. Co-authored-by: saadsheralam <[email protected]> Signed-off-by: He Xiaoqiao <[email protected]>
apache · Dec 8, 2024 · 58896f0 · 58896f0
1 parent de8b506
commit 58896f0
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...ject/hadoop-common/src/main/java/org/apache/hadoop/io/compress/BlockCompressorStream.java b/...ject/hadoop-common/src/main/java/org/apache/hadoop/io/compress/BlockCompressorStream.java
@@ -54,7 +54,11 @@ public class BlockCompressorStream extends CompressorStream {
   public BlockCompressorStream(OutputStream out, Compressor compressor, 
                                int bufferSize, int compressionOverhead) {
     super(out, compressor, bufferSize);
-    MAX_INPUT_SIZE = bufferSize - compressionOverhead;
+    if (bufferSize - compressionOverhead >= 0) {
+      MAX_INPUT_SIZE = bufferSize - compressionOverhead;
+    } else {
+      throw new IllegalArgumentException("buffer size is less than compression overhead");
+    }
   }
 
   /**