We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c8e55d2 commit e1cf530Copy full SHA for e1cf530
1 file changed
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFileReader.java
@@ -163,7 +163,7 @@ private HoodieLogBlock readBlock() throws IOException {
163
// We may have had a crash which could have written this block partially
164
// Skip blockSize in the stream and we should either find a sync marker (start of the next
165
// block) or EOF. If we did not find either of it, then this block is a corrupted block.
166
- boolean isCorrupted = isBlockCorrupt(blockStartPos, blocksize);
+ boolean isCorrupted = isBlockCorrupt(blockSize);
167
if (isCorrupted) {
168
inputStream.seek(blockStartPos);
169
return createCorruptBlock();
0 commit comments