-
Notifications
You must be signed in to change notification settings - Fork 2.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Improve page loading performance #18389
Conversation
f058275
to
2f11561
Compare
try { | ||
return mRpcFutureStub.withDeadlineAfter(mRpcTimeoutMs, TimeUnit.MILLISECONDS) | ||
return mRpcBlockingStub.withDeadlineAfter(mRpcTimeoutMs, TimeUnit.MILLISECONDS) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why changed to a blocking implementation?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
we want to make sure the first call finishes before sending the second call other the tasks in the worker queue will be disordered.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
in that case you can instead wait on the returned future instead of making it blocking.
@@ -75,13 +75,13 @@ public void put(PageId pageId, | |||
Path parent = Preconditions.checkNotNull(pagePath.getParent(), | |||
"parent of cache file should not be null"); | |||
Files.createDirectories(parent); | |||
Files.createFile(pagePath); | |||
//Files.createFile(pagePath); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this can be removed instead of commneted out
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
alluxio-bot, merge this please. |
alluxio-bot, cherry-pick this to branch-3-1.1.x please. |
### What changes are proposed in this pull request? Improve page loading performance by loading the page form UFS directly, instead of creating a reader. ### Why are the changes needed? To improve the data loading performance & reduce the memory consumption ### Does this PR introduce any user facing changes? N/A pr-link: #18389 change-id: cid-46e89dcfd22dcbbb4090df7f6c8861408ef8cb67
Auto cherry-pick to branch |
dora/core/server/worker/src/main/java/alluxio/worker/dora/PagedDoraWorker.java
Show resolved
Hide resolved
### What changes are proposed in this pull request? Improve page loading performance by loading the page form UFS directly, instead of creating a reader. ### Why are the changes needed? To improve the data loading performance & reduce the memory consumption ### Does this PR introduce any user facing changes? N/A pr-link: Alluxio#18389 change-id: cid-46e89dcfd22dcbbb4090df7f6c8861408ef8cb67
What changes are proposed in this pull request?
Improve page loading performance by loading the page form UFS directly, instead of creating a reader.
Why are the changes needed?
To improve the data loading performance & reduce the memory consumption
Does this PR introduce any user facing changes?
N/A