natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add exception message

This commit is contained in:
nivy 2026-07-21 21:32:56 -07:00
parent fa93639eb8
commit e83c85aed0
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/java/org/apache/cassandra/io/util/ThreadLocalReadAheadBuffer.java
View File

@ -18,6 +18,7 @@
package org.apache.cassandra.io.util;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.HashMap;
import java.util.Map;
@ -105,7 +106,9 @@ public class ThreadLocalReadAheadBuffer implements Closeable
Block block = getBlock();
ByteBuffer blockBuffer = block.buffer;
if (position >= channelSize)
throw new CorruptSSTableException(null, channel.filePath());
throw new CorruptSSTableException(new IOException(String.format("Chunk read past EOF: requested position %d must be less than file size %d",
position, channelSize)),
channel.filePath());
int blockNo = (int) (position / bufferSize);
long blockPosition = blockNo * (long) bufferSize;