-
Notifications
You must be signed in to change notification settings - Fork 166
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
test: Follow up on Spark 3.4 diff #209
Conversation
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## main #209 +/- ##
============================================
- Coverage 33.54% 33.54% -0.01%
- Complexity 769 770 +1
============================================
Files 107 107
Lines 35470 35517 +47
Branches 7723 7751 +28
============================================
+ Hits 11899 11913 +14
- Misses 21079 21100 +21
- Partials 2492 2504 +12 ☔ View full report in Codecov by Sentry. |
cc @viirya |
new file mode 100644 | ||
index 00000000000..4b31bea33de | ||
--- /dev/null | ||
+++ b/sql/core/src/test/scala/org/apache/spark/sql/IgnoreComet.scala |
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.
This is main change? DisableCometSuite
-> IgnoreCometSuite
?
+ op.asInstanceOf[CometExec].originalPlan.find(_.isInstanceOf[SortExec]).isDefined) | ||
+ }.isDefined == sortLeft, | ||
+ | ||
+ joinOperator.left.exists(op => op.isInstanceOf[ShuffleExchangeExec] || |
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.
here's another change
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.
For op.isInstanceOf[ShuffleExchangeExec]
, don't we need to check if it equals to shuffleLeft
?
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.
hmm? it is checked in the code:
exists(op => op.isInstanceOf[ShuffleExchangeExec] || op.isInstanceOf[CometShuffleExchangeExec]) == shuffleLeft
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.
Oh, yea, I read it wrongly.
+ op.isInstanceOf[SortExec] || | ||
+ (op.isInstanceOf[CometExec] && | ||
+ op.asInstanceOf[CometExec].originalPlan.find(_.isInstanceOf[SortExec]).isDefined) | ||
+ }.isDefined == sortLeft, |
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.
I forgot why we changed to check sort instead of shuffle here.
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.
Hmm, I remembered that I checked these parts.
Thanks, merged |
Which issue does this PR close?
Closes #.
Rationale for this change
Certain changes to address comments from #166 were somehow excluded in the final commit. This adds them back.
What changes are included in this PR?
How are these changes tested?