-
Notifications
You must be signed in to change notification settings - Fork 3.2k
Improve PageProcessor retained bytes calculations #25602
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
base: master
Are you sure you want to change the base?
Improve PageProcessor retained bytes calculations #25602
Conversation
42a58be
to
9a04414
Compare
core/trino-spi/src/main/java/io/trino/spi/connector/SourcePage.java
Outdated
Show resolved
Hide resolved
@martint I think we should also land this before the release |
I don't think this is problematic enough to block the release |
@raunaqmorarka we've been blocked for 2 weeks on that, 1 or 2 more days doesn't make a difference |
976ce28
to
92d8e30
Compare
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.
Seems fine to me. My main question is can we avoid adding the new method if we update the retainedBytesForEachPart
methods to report "this" size and sizes for internal block arrays and such. This is how RLE block works for example.
92d8e30
to
94616f2
Compare
94616f2
to
c0e0648
Compare
Yeah, that approach reduces the surface area of the |
c200d06
to
094fe0b
Compare
Ensures that all components of SourcePage implementations are accounted for in their retained bytes and retained bytes for each parts calculations to avoid under-counting the amount of memory being retained. Also ensures that PageProcessor selected positions and previouslyComputedResults array is included in the retained size.
094fe0b
to
afabcad
Compare
Description
Follows up from #25600 by account for all necessary components of
SourcePage
implementations inSourcePage#getRetainedBytes()
andSourcePage#retainedBytesForEachPart
methods. Also includesSelectedPositions
andBlock[] previouslyComputedResults
in thePageProcessor.ProjectSelectedPositions
retained size calculation.Release notes
(x) This is not user-visible or is docs only, and no release notes are required.
( ) Release notes are required. Please propose a release note for me.
( ) Release notes are required, with the following suggested text: