-
Notifications
You must be signed in to change notification settings - Fork 5.9k
planner: fix doesn't push down hash join to tiflash #60436
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?
Conversation
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## master #60436 +/- ##
================================================
+ Coverage 73.0851% 73.5364% +0.4512%
================================================
Files 1715 1715
Lines 475095 475355 +260
================================================
+ Hits 347224 349559 +2335
+ Misses 106494 104411 -2083
- Partials 21377 21385 +8
Flags with carried forward coverage won't be shown. Click here to find out more.
🚀 New features to boost your workflow:
|
/retest |
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.
Copilot reviewed 3 out of 6 changed files in this pull request and generated no comments.
Files not reviewed (3)
- pkg/planner/core/casetest/tpch/BUILD.bazel: Language not supported
- pkg/planner/core/casetest/tpch/testdata/tpch_suite_in.json: Language not supported
- pkg/planner/core/casetest/tpch/testdata/tpch_suite_out.json: Language not supported
/retest |
/retest |
/retest |
/retest |
1 similar comment
/retest |
/retest |
20161ee
to
dd48c63
Compare
/retest |
Signed-off-by: Weizhen Wang <[email protected]>
Signed-off-by: Weizhen Wang <[email protected]>
Signed-off-by: Weizhen Wang <[email protected]>
func (p *PhysicalHashJoin) enforceExchangerByBackup(task *MppTask, idx int, expectedCols int) *MppTask { | ||
if backupHashProp := p.GetChildReqProps(idx); backupHashProp != nil { | ||
if len(backupHashProp.MPPPartitionCols) == expectedCols { | ||
return task.enforceExchangerImpl(backupHashProp) |
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.
It seems we first eliminate the ex and add it back if necessary. i afraid the complicated case, currently looks fine to me
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: AilinKid, winoros The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
What problem does this PR solve?
Issue Number: close #60407
Problem Summary:
What changed and how does it work?
caused by #57417
because
NeedMPPExchangeByEquivalence
will change the hash partitioning information. Having different numbers of MPP partitions in the child nodes of a join can lead to invalid tasks, which ultimately result in incorrect plan.Check List
Tests
Side effects
Documentation
Release note
Please refer to Release Notes Language Style Guide to write a quality release note.