-
Notifications
You must be signed in to change notification settings - Fork 28.3k
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
[SPARK-44287][SQL][FOLLOWUP] Set partition index correctly #42185
Conversation
@@ -279,40 +279,36 @@ class SparkSessionExtensionSuite extends SparkFunSuite with SQLHelper { | |||
} | |||
withSession(extensions) { session => | |||
session.conf.set(SQLConf.ADAPTIVE_EXECUTION_ENABLED, enableAQE) | |||
Seq(true, false).foreach { enableEvaluator => |
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.
According to the previous discussion, we don't need to test it as we are already using the evaluator by default, and we can test RDD#mapPartitionsWithEvaluator
when we use it by default.
### What changes were proposed in this pull request? This is a followup of #41839, to set the partition index correctly even if it's not used for now. It also contains a few code cleanup. ### Why are the changes needed? future-proof ### Does this PR introduce _any_ user-facing change? no ### How was this patch tested? existing tests Closes #42185 from cloud-fan/follow. Authored-by: Wenchen Fan <wenchen@databricks.com> Signed-off-by: Wenchen Fan <wenchen@databricks.com> (cherry picked from commit bf1bbc5) Signed-off-by: Wenchen Fan <wenchen@databricks.com>
thanks for the review, merging to master/3.5! |
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.
See this later. LGTM.
I will fix the same issue I am responsible for.
### What changes were proposed in this pull request? This is a followup of apache#41839, to set the partition index correctly even if it's not used for now. It also contains a few code cleanup. ### Why are the changes needed? future-proof ### Does this PR introduce _any_ user-facing change? no ### How was this patch tested? existing tests Closes apache#42185 from cloud-fan/follow. Authored-by: Wenchen Fan <wenchen@databricks.com> Signed-off-by: Wenchen Fan <wenchen@databricks.com>
What changes were proposed in this pull request?
This is a followup of #41839, to set the partition index correctly even if it's not used for now. It also contains a few code cleanup.
Why are the changes needed?
future-proof
Does this PR introduce any user-facing change?
no
How was this patch tested?
existing tests