HADOOP-19292 Don't create new EOFException in BlockDecompressorStream

apache · Oct 1, 2024 · daa4d30 · daa4d30
1 parent 4ff0dce
commit daa4d30
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...ct/hadoop-common/src/main/java/org/apache/hadoop/io/compress/BlockDecompressorStream.java b/...ct/hadoop-common/src/main/java/org/apache/hadoop/io/compress/BlockDecompressorStream.java
@@ -126,7 +126,7 @@ protected int getCompressedData() throws IOException {
  while (n < len) {
  int count = in.read(buffer, off + n, len - n);
  if (count < 0) {
- throw new EOFException("Unexpected end of block in input stream");
+ throw EOF_EXCEPTION;
  }
  n += count;
  }
@@ -141,13 +141,15 @@ public void resetState() throws IOException {
  super.resetState();
  }
 
+ private static final EOFException EOF_EXCEPTION = new EOFException("EOF in BlockDecompressorStream");
+
  private int rawReadInt() throws IOException {
  int b1 = in.read();
  int b2 = in.read();
  int b3 = in.read();
  int b4 = in.read();
  if ((b1 | b2 | b3 | b4) < 0)
- throw new EOFException();
+ throw EOF_EXCEPTION;
  return ((b1 << 24) + (b2 << 16) + (b3 << 8) + (b4 << 0));
  }
 }