-
Notifications
You must be signed in to change notification settings - Fork 5.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
executor: more precise memory tracking #35785
executor: more precise memory tracking #35785
Conversation
[REVIEW NOTIFICATION] This pull request has been approved by:
To complete the pull request process, please ask the reviewers in the list to review by filling The full list of commands accepted by this bot can be found here. Reviewer can indicate their review by submitting an approval review. |
Code Coverage Details: https://codecov.io/github/pingcap/tidb/commit/2e1663b41160f9b535479b562882c7ebc5a6a39f |
executor/aggregate.go
Outdated
w.groupKeys = make([][]byte, len(w.groupSet.StringSet)) | ||
groupKeysIndex := 0 | ||
for groupKey := range w.groupSet.StringSet { | ||
w.groupKeys = append(w.groupKeys, []byte(groupKey)) | ||
w.groupKeys[groupKeysIndex] = []byte(groupKey) | ||
groupKeysIndex++ |
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.
w.groupKeys = make([][]byte, 0, len(w.groupSet.StringSet))
for xxxx {
w.groupKeys = append(w.groupKeys, []byte(groupKey))
}
…gxin9014/tidb into mx/preassignForPreciseMemoryTracking
executor/aggregate.go
Outdated
@@ -671,7 +673,7 @@ func (w *HashAggFinalWorker) consumeIntermData(sctx sessionctx.Context) (err err | |||
memSize := getGroupKeyMemUsage(w.groupKeys) | |||
w.groupKeys = w.groupKeys[:0] | |||
for i := 0; i < groupKeysLen; i++ { | |||
w.groupKeys = append(w.groupKeys, []byte(groupKeys[i])) | |||
w.groupKeys = append(w.groupKeys, hack.Slice(groupKeys[i])) | |||
} | |||
failpoint.Inject("ConsumeRandomPanic", nil) | |||
w.memTracker.Consume(getGroupKeyMemUsage(w.groupKeys) - memSize) |
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.
Only need consider the slice size here. We don't need to consume the memory usage of string's data, because L676 is shallow copy.
a474b86
to
cd21e7a
Compare
executor/aggregate.go
Outdated
@@ -631,6 +634,13 @@ func (w *baseHashAggWorker) getPartialResult(sc *stmtctx.StatementContext, group | |||
return partialResults | |||
} | |||
|
|||
func (w *baseHashAggWorker) getPartialResultSize() int { |
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.
getPartialResultSliceLenConsiderByteAlign ?
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.
getPartialResultSliceLenConsiderByteAlign ?
done.
executor/aggregate.go
Outdated
@@ -613,11 +613,14 @@ func (w *baseHashAggWorker) getPartialResult(sc *stmtctx.StatementContext, group | |||
if partialResults[i], ok = mapper[string(groupKey[i])]; ok { | |||
continue | |||
} | |||
for _, af := range w.aggFuncs { | |||
partialResultSize := w.getPartialResultSize() |
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.
move this line out of the loop
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.
move this line out of the loop
done.
10621a2
to
6eb1758
Compare
/run-all-tests |
/merge |
@mengxin9014: In response to this:
Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the ti-community-infra/tichi repository. |
/merge |
This pull request has been accepted and is ready to merge. Commit hash: d8a8711
|
TiDB MergeCI notify🔴 Bad News! [4] CI still failing after this pr merged.
|
…verage * upstream/master: (98 commits) planner: provide a unified interface to set and get user variables and types (pingcap#37046) *: fix check-2 to bazel (pingcap#37055) distsql: revert 37019 (pingcap#37048) planner: introduce new functions for the general statement in session interface (pingcap#37024) session: make BenchmarkCompileExecutePreparedStmt update to date (pingcap#36960) server: Change proxyprotocol to lazy mode (pingcap#36301) test: fix `TestDDLSchedulingMultiTimes` and `TestConcurrentDDLSwitch` timeout (pingcap#37043) makefile: add bazel realtikvtest (pingcap#37042) distsql: make analyze request SI (pingcap#37019) *: gofmt code for adapting go 1.19 (pingcap#36832) planner: fix data race in the TestInlineProjection4HashJoinIssue15316 (pingcap#37014) planner: introduce Session.CacheGeneralStmt for general plan cache (pingcap#37028) server: revise scheme code (pingcap#37021) planner: fix unstable test TestPushDownSelectionForMPP (pingcap#37038) executor: more precise memory tracking (pingcap#35785) executor: add privilege check for prepare stmt (pingcap#36933) *: optimize temptable.SessionSnapshotInterceptor (pingcap#36999) statistics: batch insert topn and buckets to storage to speed up loading stats (pingcap#36948) planner: remove keyword `prepared` in plan cache backend (pingcap#37023) util: fix unstable test TestCheckCN (pingcap#37016) ...
What problem does this PR solve?
Issue Number: close #36018
Problem Summary:
Memory tracking is not accurate enough.
What is changed and how it works?
Pre-allocate the size of slice to prevent adding too much memory when appending.
Check List
Tests
Side effects
Documentation
Release note
Please refer to Release Notes Language Style Guide to write a quality release note.