Skip to content

fix(top): bound distributed large Top-N merge #28288

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.

Sign up for GitHub

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

Merged
XuPeng-SH merged 9 commits into from
Sep 7, 2026
Merged

fix(top): bound distributed large Top-N merge #28288

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
ff19f95
fix(top): bound distributed large Top-N merge
XuPeng-SH Sep 6, 2026
f735bbc
fix: preserve ordered top across remote CN groups
XuPeng-SH Sep 6, 2026
76670d1
fix(top): bound spill output by payload bytes
XuPeng-SH Sep 6, 2026
f540608
fix(top): enforce payload bounds independently of estimates
XuPeng-SH Sep 7, 2026
7764c28
Merge branch 'main' into xp/fix-28285-bounded-merge-top
XuPeng-SH Sep 7, 2026
c8dfd01
fix top-n admission regressions and remote ordered write-back
XuPeng-SH Sep 7, 2026
b65946f
fix(top): decouple ordered output from spill admission
XuPeng-SH Sep 7, 2026
f8d40ae
docs(design): align bounded Top-N review record
XuPeng-SH Sep 7, 2026
e0ac370
Merge branch 'main' into xp/fix-28285-bounded-merge-top
XuPeng-SH Sep 7, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
646 changes: 646 additions & 0 deletions docs/design/bounded_distributed_topn.md
View file
Open in desktop

Large diffs are not rendered by default.

3 changes: 2 additions & 1 deletion pkg/defines/const.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,8 @@ const (
MORPCVersion50 int64 = 50 // ordered ODKU evaluation and logical affected-row metadata
MORPCVersion51 int64 = 51 // per-action ODKU validation and statement-local target arbitration
MORPCVersion52 int64 = 52 // MySQL binary JSON subtype tags
MORPCLatestVersion = MORPCVersion52
MORPCVersion53 int64 = 53 // ordered-stream distributed Top-N merge
MORPCLatestVersion = MORPCVersion53
)

// DefaultLockWaitTimeoutSeconds is shared by the frontend default and by
Expand Down
1,324 changes: 757 additions & 567 deletions pkg/pb/pipeline/pipeline.pb.go
View file
Open in desktop

Large diffs are not rendered by default.

Loading
Loading