-
Notifications
You must be signed in to change notification settings - Fork 29k
[SPARK-53128][CORE] Include unmanaged memory bytes in the usage log before execution memory OOM #51848
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
Conversation
…efore execution memory OOM
|
@ericm-db @anishshri-db Would you like to review? Thanks! |
anishshri-db
left a comment
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 - thanks !
|
@anishshri-db Thank you! |
| "{} bytes of memory are used for execution and {} bytes of memory are used for storage", | ||
| "{} bytes of memory are used for execution " + | ||
| "and {} bytes of memory are used for storage " + | ||
| "and {} bytes of memory are used but unmanaged", |
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.
Sorry but this might sounds misleading. Can we revise this like the following, @zhztheplayer ?
- and {} bytes of memory are used but unmanaged
+ and {} bytes of unmanaged memory are used
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.
Hi dongjoon-hyun, just to clarify, I guess you were suggesting to only change the 3rd sentence here?
dongjoon-hyun
left a comment
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.
+1, LGTM. Thank you, @zhztheplayer and @anishshri-db .
Merged to master/4.1 for Apache Spark 4.1.0.
…efore execution memory OOM ### What changes were proposed in this pull request? We have a log before OOM for off-heap memory allocation. Before the change, the log is: > 25/08/05 16:44:32 INFO TaskMemoryManager: 100 bytes of memory are used for execution and 100 bytes of memory are used for storage After: > 25/08/05 16:44:32 INFO TaskMemoryManager: 100 bytes of memory are used for execution and 100 bytes of memory are used for storage and 500 bytes of memory are used but unmanaged ### Why are the changes needed? Following #51708, to allow user to know the reason if the unmanaged memory causes OOM. ### Does this PR introduce _any_ user-facing change? Only changes a log message. ### How was this patch tested? Existing tests. ### Was this patch authored or co-authored using generative AI tooling? No. Closes #51848 from zhztheplayer/wip-53128. Authored-by: Hongze Zhang <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]> (cherry picked from commit c4ad381) Signed-off-by: Dongjoon Hyun <[email protected]>
|
Thank you for reviewing! |
…efore execution memory OOM ### What changes were proposed in this pull request? We have a log before OOM for off-heap memory allocation. Before the change, the log is: > 25/08/05 16:44:32 INFO TaskMemoryManager: 100 bytes of memory are used for execution and 100 bytes of memory are used for storage After: > 25/08/05 16:44:32 INFO TaskMemoryManager: 100 bytes of memory are used for execution and 100 bytes of memory are used for storage and 500 bytes of memory are used but unmanaged ### Why are the changes needed? Following apache#51708, to allow user to know the reason if the unmanaged memory causes OOM. ### Does this PR introduce _any_ user-facing change? Only changes a log message. ### How was this patch tested? Existing tests. ### Was this patch authored or co-authored using generative AI tooling? No. Closes apache#51848 from zhztheplayer/wip-53128. Authored-by: Hongze Zhang <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]>
What changes were proposed in this pull request?
We have a log before OOM for off-heap memory allocation.
Before the change, the log is:
After:
Why are the changes needed?
Following #51708, to allow user to know the reason if the unmanaged memory causes OOM.
Does this PR introduce any user-facing change?
Only changes a log message.
How was this patch tested?
Existing tests.
Was this patch authored or co-authored using generative AI tooling?
No.