Skip to content

Commit

Permalink
fix: use the "adjusted" maxSize in ElasticLogSegment#readAsync (#…
Browse files Browse the repository at this point in the history
…2184)

Signed-off-by: Ning Yu <ningyu@automq.com>
  • Loading branch information
Chillax-0v0 authored Nov 28, 2024
1 parent 64b3865 commit dab96d7
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -275,7 +275,7 @@ public CompletableFuture<FetchDataInfo> readAsync(long startOffset, int maxSize,
return CompletableFuture.completedFuture(new FetchDataInfo(offsetMetadata, MemoryRecords.EMPTY));
}

return log.read(startOffset, maxOffset, maxSize)
return log.read(startOffset, maxOffset, adjustedMaxSize)
.thenApply(records -> new FetchDataInfo(offsetMetadata, records));
}

Expand Down

0 comments on commit dab96d7

Please sign in to comment.