diff --git a/dora/core/server/worker/src/main/java/alluxio/worker/dora/PagedDoraWorker.java b/dora/core/server/worker/src/main/java/alluxio/worker/dora/PagedDoraWorker.java index 4079d0b15e5c..06483eb90c48 100644 --- a/dora/core/server/worker/src/main/java/alluxio/worker/dora/PagedDoraWorker.java +++ b/dora/core/server/worker/src/main/java/alluxio/worker/dora/PagedDoraWorker.java @@ -553,7 +553,8 @@ private boolean isAllPageCached(alluxio.grpc.UfsStatus status, long offset, long String fileId = new AlluxioURI(status.getUfsFullPath()).hash(); List cachedPages = mCacheManager.getCachedPageIdsByFileId(fileId, status.getUfsFileStatus().getContentLength()); - int numOfPagesInBlock = (int) (length / mPageSize); + // Ceiling + int numOfPagesInBlock = (int) ((length + mPageSize - 1) / mPageSize); for (long pageIndex = offset / mPageSize; pageIndex < numOfPagesInBlock; pageIndex++) { PageId pageId = new PageId(fileId, pageIndex);