Fix isAllPageCached

Cherry-pick of existing commit. orig-pr: #18347 orig-commit: ec4868d orig-commit-author: elega <[email protected]> pr-link: #18354 change-id: cid-da4bdce6615e4b1d9777a98ab335bf36e503d102
Alluxio · Nov 2, 2023 · 290cdf6 · 290cdf6
1 parent f389fa0
commit 290cdf6
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -553,7 +553,8 @@ private boolean isAllPageCached(alluxio.grpc.UfsStatus status, long offset, long
     String fileId = new AlluxioURI(status.getUfsFullPath()).hash();
     List<PageId> 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);